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

Topics (27203)

Replies

Last Post

Views

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

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21092) Introduce getJsonPlan, explainJsonPlan and executeJsonPlan in TableEnvironmentInternal by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

by Shang Yuanchun (Jira...

[DISCUSS] Correct time-related function behavior in Flink SQL by Leonard Xu

by Leonard Xu

[jira] [Created] (FLINK-21090) Enable Checkpoints after tasks finished by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21089) Skip the execution of the fully finished operators after recovery by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21088) CheckpointCoordinator pass the flag about whether a operator is fully finished on recovery by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21087) StreamTask waits for all the asynchronous step of pending checkpoint to finish by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21086) CheckpointBarrierHandler Insert barriers into channels received EndOfPartition by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21085) Refactor StreamTask hierarchy to support triggering checkpoint via RPC for non-source tasks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21084) Allows tasks to report operator subtask finish state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21083) Streaming write partitioned table needs to handle null partition value by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21082) Document how to start multiple JobManagers in HA mode for Kubernetes deployment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21081) Re-compute tasks to trigger when tasks get triggered before finished by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21080) Identify JobVertex containing legacy source operators and abort checkpoint with legacy source operators partially finished by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21079) Fink startup failed when $JAVA_HOME have space by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21078) Add DeclarativeSlotPoolService by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[Vote] FLIP-157 Migrate Flink Documentation from Jekyll to Hugo by Seth Wiesman-4

by Seth Wiesman-4

[jira] [Created] (FLINK-21077) Abstract SlotPool from JobManager by introducing SlotPoolService by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21076) Document how to use the declarative scheduler and its limitations by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21075) FLIP-160: Declarative scheduler by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink Table from KeyedStream by Dominik Wosiński

by Dominik Wosiński

[jira] [Created] (FLINK-21074) Document how to use the reactive mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21073) Mention that RocksDB ignores equals/hashCode because it works on binary data by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21072) Refactor the SnapshotStrategy hierarchy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21071) Kubernetes e2e test failed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Flink configuration from environment variables by Ingo Bürk

by Ingo Bürk

[jira] [Created] (FLINK-21070) Overloaded aggregate functions cause converter errors by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21069) Configuration "parallelism.default" doesn't take effect for TableEnvironment#explainSql by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21068) Add new timeout options for Elasticsearch connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21067) Modify the logic of computing tasks to trigger/wait/commit to consider finished tasks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21066) Refactor the CheckpointCoordinator to compute the tasks to trigger/wait/commit dynamically by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21065) Passing configuration from TableEnvironmentImpl to MiniCluster is not supported by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21064) Format docs incorrectly contain "format" property by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21063) ElasticsearchSinkITCase fails while setting up ES cluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 69707172737475 ... 778