(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 ... 76777879808182 ... 785

Topics (27473)

Replies

Last Post

Views

[jira] [Created] (FLINK-21115) Add AggregatingState and corresponding StateDescriptor for Python DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21114) Support ReducingState in Python DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21113) Add State access API for KeyedStream RuntimeContext. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21112) Add ValueState/ListState/MapState and corresponding StateDescriptors for Python DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21111) Support State access in Python DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21110) Optimize Scheduler Performance for Large-Scale Jobs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21109) Introduce "retractAccumulators" interface for AggregateFunction in Table/SQL API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21108) Flink runtime rest server and history server webmonitor do not require authentication. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21107) Move test base classes from flink-tests to flink-test-utils by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

I want to contribute to Apache Flink by 以梦为马

by Matthias

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

1 ... 76777879808182 ... 785