(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 ... 514515516517518519520 ... 1173

Topics (41038)

Replies

Last Post

Views

How to clean up resources in a UDF? by Boyuan Zhang

by Boyuan Zhang

[jira] [Created] (FLINK-19516) PerJobMiniClusterFactoryTest. testJobClient() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19515) Async RequestReply handler concurrency bug by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19514) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange times out by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Apache flink-shaded 12.0 released by Robert Metzger

by Till Rohrmann

[jira] [Created] (FLINK-19513) Update docs/build_docs.sh to support the new parameters for regenerating the docs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19512) Introduce the new sink api by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19511) Rename the `SinkTransformation` to `LegacySinkTransformation` by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19510) Introduce new unified sink api by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19509) ClassCastException for MULTISET type of JsonRowDataDeserializationSchema and JsonRowDataSerializationSchema by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19508) Add collect() operation on DataStream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] FLIP-143: Unified Sink API by Guowei Ma

by Guowei Ma

[RESULT][VOTE] Release flink-shaded 12.0 by Robert Metzger

by Robert Metzger

[jira] [Created] (FLINK-19507) Native support for Apache Pulsar by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19506) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnNonParallelLocalChannel: "Exceeded checkpoint tolerable failure threshold" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] FLIP-144: Native Kubernetes HA for Flink by Yang Wang

by Xintong Song

[VOTE] Release flink-shaded 12.0 by Robert Metzger

by Robert Metzger

[jira] [Created] (FLINK-19505) Implement distributed DSTL (DFS-based) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19504) Implement persistence for DSTL via DFS by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19503) Add DSTL interface and its in-memory implementation for testing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19502) Flink docker images: allow specifying arbitrary configuration values through environment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Dynamic Scaling: State Sharding by Till Rohrmann

by Till Rohrmann

[jira] [Created] (FLINK-19501) Missing state in enum type by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19500) Using canal-json,debezium-json,maxwell-json serialization, The DELETE semantics should be interpreted. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19499) Expose Metric Groups to Split Assigners by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19498) Port LocatableInputSplitAssigner to new File Source API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink table error in 1.11 "Could not find a suitable table factory " by Ravi Sankar Reddy Sa...

by Ravi Sankar Reddy Sa...

CheckpointedFunction initialization during checkpoint by Teng Fei Liao

by Yun Tang

[jira] [Created] (FLINK-19497) Implement mutator methods for FlinkCounterWrapper by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19496) DataGen source DECIMAL always returns null by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19495) Add documentation for avro-confluent format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19494) Adjust "StreamExecutionEnvironment.generateSequence()" to new API Sources by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19493) In CliFrontend, make flow of Configuration more obvious by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19492) Consolidate Source Events between Source API and Split Reader API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19491) AvroSerializerSnapshot cannot handle large schema by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 514515516517518519520 ... 1173