[jira] [Created] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink

2020-11-17 Thread Alexander Trushev (Jira)
Alexander Trushev created FLINK-20208: - Summary: Remove outdated in-progress files in StreamingFileSink Key: FLINK-20208 URL: https://issues.apache.org/jira/browse/FLINK-20208 Project: Flink

Re: [ANNOUNCE] Weekly Community Update 2020/44-45

2020-11-17 Thread Konstantin Knauf
I don't think so. I am sure there will be another patch release for Flink 1.10, but it has not been discussed yet. The community is currently focusing on release testing Flink 1.12. I could imagine that the discussion for 1.10.3 is only started afterwards. On Tue, Nov 17, 2020 at 3:04 PM chohan w

[jira] [Created] (FLINK-20207) Improve the error message printed when submitting the pyflink jobs via 'flink run'

2020-11-17 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-20207: - Summary: Improve the error message printed when submitting the pyflink jobs via 'flink run' Key: FLINK-20207 URL: https://issues.apache.org/jira/browse/FLINK-20207 Project:

[jira] [Created] (FLINK-20206) Failed to start the session, but there is no clear prompt.

2020-11-17 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-20206: - Summary: Failed to start the session, but there is no clear prompt. Key: FLINK-20206 URL: https://issues.apache.org/jira/browse/FLINK-20206 Project: Flink Issue Ty

[jira] [Created] (FLINK-20205) CDC source shouldn't send UPDATE_BEFORE messages if the downstream doesn't need it

2020-11-17 Thread Jark Wu (Jira)
Jark Wu created FLINK-20205: --- Summary: CDC source shouldn't send UPDATE_BEFORE messages if the downstream doesn't need it Key: FLINK-20205 URL: https://issues.apache.org/jira/browse/FLINK-20205 Project: Fli

Re: [DISCUSS] Stop adding new bash-based e2e tests to Flink

2020-11-17 Thread Yang Wang
Thanks for starting this discussion. In general, I agree with you that a java-based testing framework is better than the bash-based. It will help a lot for the commons and utilities. Since I am trying to add a new bash-based Kubernetes HA test, I have some quick questions. * I am not sure where t

[jira] [Created] (FLINK-20204) Translate page 'upsert-kafka Connector' into Chinese

2020-11-17 Thread CaoZhen (Jira)
CaoZhen created FLINK-20204: --- Summary: Translate page 'upsert-kafka Connector' into Chinese Key: FLINK-20204 URL: https://issues.apache.org/jira/browse/FLINK-20204 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-20203) Could not find any document about how to build a Flink image from local build.

2020-11-17 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-20203: - Summary: Could not find any document about how to build a Flink image from local build. Key: FLINK-20203 URL: https://issues.apache.org/jira/browse/FLINK-20203 Project: Fli

Re: [DISCUSS] Releasing Apache Flink 1.11.3

2020-11-17 Thread Xintong Song
Hi devs, Updates on the progress of preparing the 1.11.3 release. We are approaching the creation of our first release candidate. Thanks all for the efforts so far. # Ongoing threads - *FLIP-27 backportings:* 74 out of 102 commits are already backported. Stephan and Becket are actively wo

[jira] [Created] (FLINK-20202) Add the Check of Unsupported Result Type in Pandas UDAF

2020-11-17 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20202: Summary: Add the Check of Unsupported Result Type in Pandas UDAF Key: FLINK-20202 URL: https://issues.apache.org/jira/browse/FLINK-20202 Project: Flink Issue

[jira] [Created] (FLINK-20201) Support automatic adjustment of window parameters

2020-11-17 Thread lqjacklee (Jira)
lqjacklee created FLINK-20201: - Summary: Support automatic adjustment of window parameters Key: FLINK-20201 URL: https://issues.apache.org/jira/browse/FLINK-20201 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-20200) SQL Hints are not supported in "Create View" syntax

2020-11-17 Thread shizhengchao (Jira)
shizhengchao created FLINK-20200: Summary: SQL Hints are not supported in "Create View" syntax Key: FLINK-20200 URL: https://issues.apache.org/jira/browse/FLINK-20200 Project: Flink Issue Ty

[jira] [Created] (FLINK-20199) PyFlink unstable e2e DataStream test

2020-11-17 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20199: Summary: PyFlink unstable e2e DataStream test Key: FLINK-20199 URL: https://issues.apache.org/jira/browse/FLINK-20199 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20198) Liquid Exception: Could not find document 'dev/table/connectors/formats/index.md' in tag 'link'. Make sure the document exists and the path is correct. in dev/table/conn

2020-11-17 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20198: Summary: Liquid Exception: Could not find document 'dev/table/connectors/formats/index.md' in tag 'link'. Make sure the document exists and the path is correct. in dev/table/connectors/upsert-kafka.zh.md

[jira] [Created] (FLINK-20197) FileSink fails with UnsupportedOperationException when using default values

2020-11-17 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20197: - Summary: FileSink fails with UnsupportedOperationException when using default values Key: FLINK-20197 URL: https://issues.apache.org/jira/browse/FLINK-20197 Project

[jira] [Created] (FLINK-20196) flink-connector-files needs explicit flink-connector-base dependency to run

2020-11-17 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20196: - Summary: flink-connector-files needs explicit flink-connector-base dependency to run Key: FLINK-20196 URL: https://issues.apache.org/jira/browse/FLINK-20196 Project

[jira] [Created] (FLINK-20195) Jobs endpoint returns duplicated jobs

2020-11-17 Thread Jira
Ingo Bürk created FLINK-20195: - Summary: Jobs endpoint returns duplicated jobs Key: FLINK-20195 URL: https://issues.apache.org/jira/browse/FLINK-20195 Project: Flink Issue Type: Bug Affects V

Job Manager is taking very long time to finalize the Checkpointing.

2020-11-17 Thread Slim Bouguerra
Hi Devs, I am very new to the Flink code base and working on the evaluation of the Checkpointing strategy In my current setup I am using an NFS based file system as a checkpoint store. (NAS/NFS has a very high TP over 2GB/s on one node and I am using 12 NFS servers ) When pushing the system to so

[DISCUSS] Stop adding new bash-based e2e tests to Flink

2020-11-17 Thread Robert Metzger
Hi all, Since we are currently testing the 1.12 release, and potentially adding more automated e2e tests, I would like to bring up our end to end tests for discussion. Some time ago, we introduced a Java-based testing framework, with the idea of replacing the current bash-based end to end tests.

[jira] [Created] (FLINK-20194) KafkaSourceFetcherManager.commitOffsets() should handle the case when there is no split fetcher.

2020-11-17 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-20194: Summary: KafkaSourceFetcherManager.commitOffsets() should handle the case when there is no split fetcher. Key: FLINK-20194 URL: https://issues.apache.org/jira/browse/FLINK-20194

[jira] [Created] (FLINK-20193) SourceCoordinator should catch exception thrown from SplitEnumerator.start()

2020-11-17 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-20193: Summary: SourceCoordinator should catch exception thrown from SplitEnumerator.start() Key: FLINK-20193 URL: https://issues.apache.org/jira/browse/FLINK-20193 Project:

Re: [ANNOUNCE] Weekly Community Update 2020/44-45

2020-11-17 Thread chohan
Is there a place to track the 1.10.3 release? I see discussion for 1.11.3 [0] but nothing for 1.10.3. [0] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Releasing-Apache-Flink-1-11-3-td45989.html -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.co

[jira] [Created] (FLINK-20192) Externalized checkpoint references a checkpoint from a different job

2020-11-17 Thread Antti Kaikkonen (Jira)
Antti Kaikkonen created FLINK-20192: --- Summary: Externalized checkpoint references a checkpoint from a different job Key: FLINK-20192 URL: https://issues.apache.org/jira/browse/FLINK-20192 Project: F

[jira] [Created] (FLINK-20191) Add document for per-partition-watermark kafka in table api

2020-11-17 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-20191: - Summary: Add document for per-partition-watermark kafka in table api Key: FLINK-20191 URL: https://issues.apache.org/jira/browse/FLINK-20191 Project: Flink

[jira] [Created] (FLINK-20190) A New Window Trigger that can trigger window operation by event time interval、event count

2020-11-17 Thread GaryGao (Jira)
GaryGao created FLINK-20190: --- Summary: A New Window Trigger that can trigger window operation by event time interval、event count Key: FLINK-20190 URL: https://issues.apache.org/jira/browse/FLINK-20190 Proje

[jira] [Created] (FLINK-20189) Restored feedback events may be silently dropped if per key-group header bytes were not fully read

2020-11-17 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-20189: --- Summary: Restored feedback events may be silently dropped if per key-group header bytes were not fully read Key: FLINK-20189 URL: https://issues.apache.org/jira/brow

[jira] [Created] (FLINK-20188) Add Documentation for new File Source

2020-11-17 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-20188: Summary: Add Documentation for new File Source Key: FLINK-20188 URL: https://issues.apache.org/jira/browse/FLINK-20188 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-20187) FactoryUtil#createTableSource will be confused by a table source and a table sink factory with same identifier

2020-11-17 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-20187: --- Summary: FactoryUtil#createTableSource will be confused by a table source and a table sink factory with same identifier Key: FLINK-20187 URL: https://issues.apache.org/jira/browse/F

[jira] [Created] (FLINK-20186) FactoryUtil will give an incorrect error message when multiple factories fit the connector identifier

2020-11-17 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-20186: --- Summary: FactoryUtil will give an incorrect error message when multiple factories fit the connector identifier Key: FLINK-20186 URL: https://issues.apache.org/jira/browse/FLINK-2018