[jira] [Created] (FLINK-19432) Whether to capture the updates which don't change any monitored columns

tinny cat created FLINK-19432: - Summary: Whether to capture the updates which don't change any monitored columns Key: FLINK-19432 URL: https://issues.apache.org/jira/browse/FLINK-19432 Project: Flink

Re: [DISCUSS] FLIP-143: Unified Sink API

Hi Steven Thank you very much for your detailed explanation. Now I got your point, I could see that there are benefits from committing a collection of `GlobalCommT` as a whole when the external metastore environment is unstable at some time. But I have two little concern about introducing commit

Re: [DISCUSS] FLIP-142: Disentangle StateBackends from Checkpointing

Thanks Seth, the updated FLIP overall LGTM, and I've left some inline comments in the doc. Best Regards, Yu On Fri, 25 Sep 2020 at 20:58, Seth Wiesman wrote: > Done > > Seth > > On Fri, Sep 25, 2020 at 2:47 AM Yu Li wrote: > > > *bq. I think it might help to highlight specific stumbling block

[jira] [Created] (FLINK-19431) Translate "Monitoring REST API" page of "Debugging & Monitoring" into Chinese

weizheng created FLINK-19431: Summary: Translate "Monitoring REST API" page of "Debugging & Monitoring" into Chinese Key: FLINK-19431 URL: https://issues.apache.org/jira/browse/FLINK-19431 Project: Flink

[RESULT] [VOTE] Apache Flink Stateful Functions 2.2.0, release candidate #2

Thanks for testing and voting everyone! The vote has passed with 5 +1 votes, 3 of which are binding: +1: - Igal Shilman - Seth Wiesman - Tzu-Li (Gordon) Tai (binding) - Aljoscha Krettek (binding) - Piotr Nowojski (binding) There are no 0 or -1 votes. I'll announce the release in a separate emai

[jira] [Created] (FLINK-19430) Translate page 'datastream_tutorial' into Chinese

hailong wang created FLINK-19430: Summary: Translate page 'datastream_tutorial' into Chinese Key: FLINK-19430 URL: https://issues.apache.org/jira/browse/FLINK-19430 Project: Flink Issue Type:

[jira] [Created] (FLINK-19429) Translate page 'Data Types' into Chinese

hailong wang created FLINK-19429: Summary: Translate page 'Data Types' into Chinese Key: FLINK-19429 URL: https://issues.apache.org/jira/browse/FLINK-19429 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-19428) Translate "Elasticsearch Connector" page of "DataStream Connectors" into Chinese

weizheng created FLINK-19428: Summary: Translate "Elasticsearch Connector" page of "DataStream Connectors" into Chinese Key: FLINK-19428 URL: https://issues.apache.org/jira/browse/FLINK-19428 Project: Fli

[jira] [Created] (FLINK-19427) SplitFetcherTest.testNotifiesWhenGoingIdleConcurrent is instable

Dian Fu created FLINK-19427: --- Summary: SplitFetcherTest.testNotifiesWhenGoingIdleConcurrent is instable Key: FLINK-19427 URL: https://issues.apache.org/jira/browse/FLINK-19427 Project: Flink Issue

[jira] [Created] (FLINK-19426) Streaming File Sink end-to-end test is instable

Dian Fu created FLINK-19426: --- Summary: Streaming File Sink end-to-end test is instable Key: FLINK-19426 URL: https://issues.apache.org/jira/browse/FLINK-19426 Project: Flink Issue Type: Bug

Re: [DISCUSS] FLIP-145: Support SQL windowing table-valued function

Hi pengcheng, That's great to see you also have the need of window join. You are right, the windowing TVF is a powerful feature which can support more operations in the future. I think it as of the date time "partition" selection in batch SQL jobs, with this new syntax, I think it is possible to

[jira] [Created] (FLINK-19425) Correct the usage of BulkWriter#flush and BulkWriter#finish

hailong wang created FLINK-19425: Summary: Correct the usage of BulkWriter#flush and BulkWriter#finish Key: FLINK-19425 URL: https://issues.apache.org/jira/browse/FLINK-19425 Project: Flink

[jira] [Created] (FLINK-19424) Translate page 'Query Configuration' into Chinese

hailong wang created FLINK-19424: Summary: Translate page 'Query Configuration' into Chinese Key: FLINK-19424 URL: https://issues.apache.org/jira/browse/FLINK-19424 Project: Flink Issue Type:

[jira] [Created] (FLINK-19423) primary key position cause JDBC SQL upsert sink ArrayIndexOutOfBoundsException

limbo created FLINK-19423: - Summary: primary key position cause JDBC SQL upsert sink ArrayIndexOutOfBoundsException Key: FLINK-19423 URL: https://issues.apache.org/jira/browse/FLINK-19423 Project: Flink