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

Topics (27203)

Replies

Last Post

Views

[jira] [Created] (FLINK-19724) tableEnv.toRetractStream(table, PoJo.class) when by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19723) The retry mechanism of jdbc connector has the risk of data duplication by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19722) Pushdown Watermark to SourceProvider (new Source) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19721) Speed up the frequency of checks in RpcGatewayRetriever by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19720) Introduce DataStream and Source Providers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19719) FLIP-146: Improve new TableSource and TableSink interfaces by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] FLIP-146: Improve new TableSource and TableSink interfaces by Jingsong Li

by Jingsong Li

[jira] [Created] (FLINK-19718) HiveTableSourceITCase.testStreamPartitionRead is not stable on Azure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19716) [Kinesis][EFO] Unable to use Assume Role with EFO record publisher by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19715) Optimize re-assignment of excess resources by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19714) Assign different logical pipelined regions of a DataSet job to different slot sharing group by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19713) Update `JobGraphUtils` type to class by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19712) Pipelined region failover should skip restarting tasks in CREATED by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-135: Approximate Task-Local Recovery by curcur

by Piotr Nowojski-5

[jira] [Created] (FLINK-19711) Parsing of invalid CSV fails even with ignoreParseErrors is enabled by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19710) Avoid performance regression introduced by thread-local keyword of FRocksDB by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19709) Support KeyedSortedMapState in DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19708) Support KeyedSortedMapState in DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19707) Refactor table streaming file sink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19706) Introduce `Repeated Partition Commit Check` in `org.apache.flink.table.filesystem.PartitionCommitPolicy` by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19705) Avro Confluent Schema Registry nightly end-to-end test: curl: (56) Recv failure: Connection reset by peer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19704) Flink checkpoint will fail when keytab dir meets a failure, and the flink should handle it. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19703) A result partition is not untracked after its producer task failed in TaskManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re： [VOTE] FLIP-146: Improve new TableSource and TableSink interfaces by 刘首维

by 刘首维

[jira] [Created] (FLINK-19702) Avoid using HiveConf::hiveSiteURL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19701) Unaligned Checkpoint might misuse the number of buffers to persist from the previous barrier by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19700) Make Kubernetes Client in KubernetesResourceManagerDriver use io executor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19699) PrometheusReporterEndToEndITCase crashes with exit code 143 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19698) Add close() method and onCheckpointComplete() to the Source. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19697) Make the streaming committer retry-able by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19696) Implement Batch committer for the new API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19695) Writing Table with RowTime Column of type TIMESTAMP(3) to Kafka fails with ClassCastException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19694) Support [UPDATE_AFTER, DELETE] ChangelogMode for ScanTableSource by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] Add Translation Specification for Stateful Functions by Congxian Qiu

by Congxian Qiu

1 ... 112113114115116117118 ... 778