(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 ... 64656667686970 ... 778

Topics (27218)

Replies

Last Post

Views

[jira] [Created] (FLINK-21262) Remove SlotPool.suspend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLINK-21045: Support 'load module' and 'unload module' SQL syntax by Jane Chan

by Jark Wu-2

[VOTE] FLIP-159: Reactive Mode by Robert Metzger

by Robert Metzger

[jira] [Created] (FLINK-21261) Improve digest of physical Expand node by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21260) Add DeclarativeScheduler / Finished state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21259) Add DeclarativeScheduler / Failing state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21258) Add DeclarativeScheduler / Canceling state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21257) Add DeclarativeScheduler / Restarting state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21256) Add DeclarativeScheduler / Executing state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21255) Add DeclarativeScheduler / WaitingForResources state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21254) Add DeclarativeScheduler / Created state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21253) Support grouping set/cube/rollup syntax in WindowAggregate by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21252) Scala quickstarts should specify -target jvm version by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21251) Last valid checkpoint metadata lost after job exits restart loop by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21250) Failure to finalize checkpoint due to org.apache.hadoop.fs.FileAlreadyExistsException: /user/flink/checkpoints/9e36ed4ec2f6685f836e5ee5395f5f2e/chk-11096/_metadata for client xxx.xx.xx.xxx already exists by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21249) TableEnvironment does not support create method with remote nvironment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21248) Checkpoint problem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] FLIP-156: Runtime Interfaces for Fine-Grained Resource Requirements by Yangze Guo

by Zhu Zhu

[jira] [Created] (FLINK-21247) flink iceberg table map<string,string> cannot convert to datastream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21246) Decline Checkpoint if some tasks finished before get triggered by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21245) Support StreamExecCalc json serialization/deserialization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21244) shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel Fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLINK-21110: Optimize Scheduler Performance for Large-Scale Jobs by Zhilong Hong

by Guowei Ma

[jira] [Created] (FLINK-21243) Add Java SDK maven module by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21242) Support state access API for map operation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21241) E2E test exception check might fail if older checkpoint not completed when triggering the stop-with-savepoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21240) incompati datetime by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21239) Upgrade Calcite version to 1.28 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21238) Support to close PythonFunctionFactory manually by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21237) Reflects the actual running state of the job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21236) Don't explicitly use HeapMemorySegment in row format serde by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21235) leaderChange_withBlockingJobManagerTermination_doesNotAffectNewLeader hang by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21234) testKafkaSourceSinkWithKeyAndPartialValue[legacy = false, format = csv] hang by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21233) Race condition in CheckpointCoordinator in finishing sync savepoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: [DISCUSS] Support obtaining Hive delegation tokens when submitting application to Yarn by jie.wang

by Jack W

1 ... 64656667686970 ... 778