[jira] [Created] (FLINK-26084) Python tests exit with code 137

2022-02-10 Thread Yun Gao (Jira)
Yun Gao created FLINK-26084: --- Summary: Python tests exit with code 137 Key: FLINK-26084 URL: https://issues.apache.org/jira/browse/FLINK-26084 Project: Flink Issue Type: Bug Components: A

[jira] [Created] (FLINK-26083) CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink failed on azure due to table exists

2022-02-10 Thread Yun Gao (Jira)
Yun Gao created FLINK-26083: --- Summary: CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink failed on azure due to table exists Key: FLINK-26083 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Created] (FLINK-26082) CancelPartitionRequestTest.testDuplicateCancel failed on azure due to bind failed

2022-02-10 Thread Yun Gao (Jira)
Yun Gao created FLINK-26082: --- Summary: CancelPartitionRequestTest.testDuplicateCancel failed on azure due to bind failed Key: FLINK-26082 URL: https://issues.apache.org/jira/browse/FLINK-26082 Project: Flin

Re: Azure Pipelines are dealing with an incident, causing pipeline runs to fail

2022-02-10 Thread Biao Geng
Just notice that there are some recent pipelines that have finished successfully[1]. It seems that this issue is mitigated. [1] https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=31194&view=results Martijn Visser 于2022年2月10日周四 15:48写道: > It looks like the issues haven't been

[jira] [Created] (FLINK-26081) Update document,becasue of add maven wapper.

2022-02-10 Thread Aiden Gong (Jira)
Aiden Gong created FLINK-26081: -- Summary: Update document,becasue of add maven wapper. Key: FLINK-26081 URL: https://issues.apache.org/jira/browse/FLINK-26081 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-26080) PartitionRequest client use Netty's IdleStateHandler to monitor channel's status

2022-02-10 Thread Cai Liuyang (Jira)
Cai Liuyang created FLINK-26080: --- Summary: PartitionRequest client use Netty's IdleStateHandler to monitor channel's status Key: FLINK-26080 URL: https://issues.apache.org/jira/browse/FLINK-26080 Projec

[jira] [Created] (FLINK-26079) Disallow combination of Changelog backend and CLAIM restore mode

2022-02-10 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-26079: - Summary: Disallow combination of Changelog backend and CLAIM restore mode Key: FLINK-26079 URL: https://issues.apache.org/jira/browse/FLINK-26079 Project:

Re: [DISCUSS] FLINK-25927: Make flink-connector-base dependency usage consistent across all connectors

2022-02-10 Thread Thomas Weise
Hi Alexander, It is beneficial for users to be able to replace/choose a connector as part of their application. When flink-connector-base is included in dist, that becomes more difficult. We can run into hard to understand dependency conflicts such as [1]. Depending on the Flink platform used, it

[jira] [Created] (FLINK-26078) Initial Kubernetes Operator Prototype contribution

2022-02-10 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-26078: -- Summary: Initial Kubernetes Operator Prototype contribution Key: FLINK-26078 URL: https://issues.apache.org/jira/browse/FLINK-26078 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-26077) Support operators send request to Coordinator and return a response

2022-02-10 Thread Jark Wu (Jira)
Jark Wu created FLINK-26077: --- Summary: Support operators send request to Coordinator and return a response Key: FLINK-26077 URL: https://issues.apache.org/jira/browse/FLINK-26077 Project: Flink Is

[jira] [Created] (FLINK-26076) Fix ArchUnit violations in SourceMetricsITCase

2022-02-10 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-26076: Summary: Fix ArchUnit violations in SourceMetricsITCase Key: FLINK-26076 URL: https://issues.apache.org/jira/browse/FLINK-26076 Project: Flink Issue

[jira] [Created] (FLINK-26075) Persist per-ExecNode configuration

2022-02-10 Thread Timo Walther (Jira)
Timo Walther created FLINK-26075: Summary: Persist per-ExecNode configuration Key: FLINK-26075 URL: https://issues.apache.org/jira/browse/FLINK-26075 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26074) Improve FlameGraphs scalability for high parallelism jobs

2022-02-10 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-26074: - Summary: Improve FlameGraphs scalability for high parallelism jobs Key: FLINK-26074 URL: https://issues.apache.org/jira/browse/FLINK-26074 Project: Flink

RE: Re: [DISCUSS] FLIP-213: TaskManager's Flame Graphs

2022-02-10 Thread Jacky Lau
Hi Alexander: Sorry for late response for Chinese Spring Festival. The bottleneck is rendering on the browser side. For 1) we support user define script capability like yarn. And the flame graph script just encapsulate async profiler. So we should make it secure. For 2) yeah, we use di

Re: [VOTE] Deprecate Cassandra connector

2022-02-10 Thread Martijn Visser
Hi everyone, I've cancelled the vote since Marco Zühlke volunteered to help with the Cassandra contributions [1]. Best regards, Martijn [1] https://lists.apache.org/thread/1qokt5tp8dcp58dmshbwjc43ssbm1vvk On Mon, 31 Jan 2022 at 12:40, Ada Wong wrote: > +1 > > Martijn Visser 于2022年1月31日周一 18

Re: [VOTE] Deprecate NiFi connector

2022-02-10 Thread Martijn Visser
Hi everyone, Thanks for your votes, I'm closing the vote and I'll post the results shortly. Best regards, Martijn On Fri, 4 Feb 2022 at 11:18, Chesnay Schepler wrote: > +1 > > On 31/01/2022 11:46, Martijn Visser wrote: > > Hi everyone, > > > > I would like to open up a vote to deprecate NiFi

Re: [VOTE] Remove Twitter connector

2022-02-10 Thread Martijn Visser
Hi everyone, Thanks for your votes, I'm closing the vote and I'll post the results shortly. Best regards, Martijn On Thu, 3 Feb 2022 at 16:33, David Anderson wrote: > +1 > > On Mon, Jan 31, 2022 at 11:47 AM Martijn Visser > wrote: > > > Hi everyone, > > > > I would like to open up a vote to

[RESULT][VOTE] Remove Twitter connector

2022-02-10 Thread Martijn Visser
Hi everyone, The Flink community has unanimously approved to remove the Twitter connector as of Flink 1.15. There were 4 binding votes [1] Ingo Bürk Fabian Paul Seth Wiesman David Anderson Best regards, Martijn Visser https://twitter.com/MartijnVisser82 [1] https://lists.apache.org/thread/b9m

[jira] [Created] (FLINK-26073) Remove Twitter connector

2022-02-10 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-26073: -- Summary: Remove Twitter connector Key: FLINK-26073 URL: https://issues.apache.org/jira/browse/FLINK-26073 Project: Flink Issue Type: Technical Debt

[RESULT][VOTE] [VOTE] Deprecate NiFi connector

2022-02-10 Thread Martijn Visser
Hi everyone, The Flink community has voted and accepted to deprecate the NiFi connector in Flink 1.15 and remove it in the next version. It has been unanimously approved [1] Binding +1: Fabian Paul Konstantin Knauf Seth Wiesman Chesnay Schepler Best regards, Martijn Visser https://twitter.com

[jira] [Created] (FLINK-26072) Mark NiFi connector as deprecated

2022-02-10 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-26072: -- Summary: Mark NiFi connector as deprecated Key: FLINK-26072 URL: https://issues.apache.org/jira/browse/FLINK-26072 Project: Flink Issue Type: Technical D

[jira] [Created] (FLINK-26071) TableEnvironment#compilePlan should fail

2022-02-10 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-26071: --- Summary: TableEnvironment#compilePlan should fail Key: FLINK-26071 URL: https://issues.apache.org/jira/browse/FLINK-26071 Project: Flink Issue

[jira] [Created] (FLINK-26070) Update dependency numpy to >=1.21.0,<1.22

2022-02-10 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-26070: -- Summary: Update dependency numpy to >=1.21.0,<1.22 Key: FLINK-26070 URL: https://issues.apache.org/jira/browse/FLINK-26070 Project: Flink Issue Type: Tec

Re: [DISCUSS]Support the merge statement in FlinkSQL

2022-02-10 Thread Martijn Visser
Hi zoucao, I see that this message was posted twice, so I choose to only reply to the latest one (this one). Thanks for bringing this up for discussion. I agree that support for a merge statement would be a welcome addition to Flink SQL for those that are using it for bounded jobs. How would you