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

Topics (27203)

Replies

Last Post

Views

about flink calcite implement by laughing.sheng@qq.co...

by Kurt Young

[jira] [Created] (FLINK-21124) Checkpoint abort RPC can be ignored in some cases by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21123) Upgrade Beanutils 1.9.x to 1.9.4 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21122) Update docs/ops/monitoring/checkpoint_monitoring.zh.md by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21121) TaggedOperatorSubtaskState is missing when creating a new savepoint using state processor api by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21120) Add support for ignore abnormal watermark by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21119) Building Flink Azure FS Hadoop hangs during python CI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21118) TPC-DS end-to-end test (Blink planner) fails with "no more allocated slots" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21117) KafkaProducerExactlyOnceITCase fails with "Exceeded checkpoint tolerable failure threshold." by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21116) DefaultDispatcherRunnerITCase hangs on azure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

1 ... 68697071727374 ... 778