(DEPRECATED) Apache Flink Mailing List archive.

This used to be a public archive of the Flink mailing mailing list.

We recommend using the official Apache Mailing List Archive: https://lists.apache.org/list.html?dev@flink.apache.org

New Topic

People

1 ... 75767778798081 ... 778

Topics (27203)

Replies

Last Post

Views

[jira] [Created] (FLINK-20912) Increase Log and Metric: Time consumed by Checkpoint Restore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20911) Support to modify RocksDB LOG level by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20910) Remove restriction on StreamPhysicalGroupWindowAggregate that StreamPhysicalGroupWindowAggregate only support insert-only input node by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20909) MiniBatch Interval derivation does not work well when enable miniBatch optimization in a job which contains deduplicate on row and unbounded aggregate. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20908) ShardConsumerFanOutTest.testStartFromLatestIsTranslatedToTimestamp test failed with AssertionError by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20907) Table API documentation promotes deprecated syntax by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20906) Update copy right year to 2021 for NOTICE files by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20905) Format the description of 'kubernetes.container.image' option by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20904) Maven enforce goal dependency-convergence failed on flink-avro-glue-schema-registry by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Core limit exceeded in GridGain Control Center by Carsten

by Carsten

[jira] [Created] (FLINK-20903) Remove SchedulerNG.initialize method by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Kafka producer exactly once by Pramod Immaneni-2

by Piotr Nowojski-5

[jira] [Created] (FLINK-20902) Please remove my email id by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Support local aggregate push down for Blink batch planner by Sebastian Liu

by Jark Wu-2

[jira] [Created] (FLINK-20901) Introduce DeclarativeSlotPool methods to set resource requirements to absolute values by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20900) Extend documentation guidelines to cover formatting of commands by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20899) encounter ClassCastException when calculating cost in HepPlanner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20898) Code of BatchExpand & LocalNoGroupingAggregateWithoutKeys grows beyond 64 KB by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20897) Support DataStream batch mode in StreamTableEnvironment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20896) [Local Agg Pushdown] Support SupportsAggregatePushDown for JDBC TableSource by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20895) [Local Agg Pushdown] Support LocalAggregatePushDown in Blink planner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20894) [Local Agg Pushdown] Introduce SupportsAggregatePushDown interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20893) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel test failed with "TestTimedOutException" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

About JobMananger metrics scope by Lu Niu

by Chesnay Schepler-3

[DISCUSS] FLIP-155: Introduce a few convenient operations in Table API by Dian Fu-2

by Timo Walther-2

[jira] [Created] (FLINK-20892) Remove ScheduledUnit interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20891) SystemResourcesCounterTest may caused endless loop when some error occured by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20890) flink-state-processor-api: differents serializers being taken from Flink & State processor api by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20889) How does flink 1.12 support modifying jobName by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20888) ContinuousFileReaderOperator should not close the output on close() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20887) Non-deterministic functions return different values even if it is referred with the same column name by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20886) Add the option to get a threaddump on checkpoint timeouts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20884) NullPointerException in create statements with computed columns which the subQuery is SqlNodeList by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20883) Separate the implementation of BatchExecOverAggregate and StreamExecOverAggregate by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 75767778798081 ... 778