(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 (27218)

Replies

Last Post

Views

[jira] [Created] (FLINK-19739) CompileException when windowing in batch mode: A method named "replace" is not declared in any enclosing class nor any supertype by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19738) Remove the `getCommitter` from the `AbstractStreamingCommitterOperator` by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19737) Introduce TableOperatorWrapperGenerator to translate transformation DAG in a multiple-input node to TableOperatorWrapper DAG by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19736) Implement the `SinkTransformation` by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19735) TableFunction can not work in Flink View by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19734) Add scan-only TableSoure tests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19733) Make fast_operation and slow_operation produce functions consistent by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19732) Disable Checkpointing when in BATCH mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19731) 使用了批量执行SQL的api，job执行的时候，DataStream 不触发 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19730) Create the CoFeedbackTransformation translator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19729) Create the FeedbackTransformation translator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19728) YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19727) Implement ParallelismProvider for sink in blink planner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19726) Implement new providers for blink planner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19725) DataStreamTests.test_key_by_on_connect_stream is failed on Azure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

1 ... 112113114115116117118 ... 778