(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 (27218)

Replies

Last Post

Views

[jira] [Created] (FLINK-21106) google-java-format Intellij Plugin 1.7.0.5 causes UnsupportedOperationException in IntelliJ by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21105) Rename ExecEdge to InputProperty by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21104) UnalignedCheckpointITCase.execute failed with "IllegalStateException" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21103) E2e tests time out on azure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21102) Add ScaleUpController by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21101) Set up cron job to run CI with declarative scheduler by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21100) Add DeclarativeScheduler skeleton by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21099) Introduce JobType to distinguish between batch and streaming jobs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21098) Add SlotAllocator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21097) Introduce e2e test framework for json plan test by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] 1.12.1 may still produce corrupted checkpoints by Arvid Heise-4

by Arvid Heise-4

[ANNOUNCE] Welcome Guowei Ma as a new Apache Flink Committer by Kurt Young

by pez1420@163.com

[jira] [Created] (FLINK-21096) Introduce ExecNodeGraphJsonPlanGenerator to serialize ExecNodeGraph to json plan and deserialize json plan to ExecNodeGraph by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21095) Remove legacy slotmanagement profile by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

by Shang Yuanchun (Jira...

[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...

1 ... 69707172737475 ... 778