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

Topics (27218)

Replies

Last Post

Views

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

[jira] [Created] (FLINK-19490) Document SOMAXCONN OS limit on blob server backlog by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

by Yang Wang

[jira] [Created] (FLINK-19489) SplitFetcherTest.testNotifiesWhenGoingIdleConcurrent gets stuck by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19488) Failed compilation of generated class by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19487) Checkpoint start delay is always zero for single channel tasks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19486) expected: class org.apache.flink.runtime.state.KeyGroupsStateHandle, but found: class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 119120121122123124125 ... 778