[jira] [Created] (FLINK-18535) Elasticsearch connector hangs for threads deadlocked

2020-07-08 Thread DeFOX (Jira)
DeFOX created FLINK-18535: - Summary: Elasticsearch connector hangs for threads deadlocked Key: FLINK-18535 URL: https://issues.apache.org/jira/browse/FLINK-18535 Project: Flink Issue Type: Bug

Re: [DISCUSS] Releasing Flink 1.11.1 soon?

2020-07-08 Thread Jark Wu
Besides, it would be great if we can figure out the performance regression Thomas reported before. Do you know what's the status now? @zhijiang @Thomas Best, Jark On Thu, 9 Jul 2020 at 11:10, Jark Wu wrote: > Hi everyone, > > As discussed in the voting thread of 1.11.0-RC4 [1], we found a bl

[DISCUSS] Releasing Flink 1.11.1 soon?

2020-07-08 Thread Jark Wu
Hi everyone, As discussed in the voting thread of 1.11.0-RC4 [1], we found a blocker issue about the CDC feature [1]. Considering this is a new kind of connector, we don't want to block the ready-to-publish RC4 and prefer to have an immediately 1.11.1 release. Therefore, I would like to start the

Re: [DISCUSS] FLIP-130: Support for Python DataStream API (Stateless Part)

2020-07-08 Thread Xingbo Huang
Hi Shuiqiang, Thanks a lot for driving this discussion. Big +1 for supporting Python DataStream. In many ML scenarios, operating Object will be more natural than operating Table. Best, Xingbo Wei Zhong 于2020年7月9日周四 上午10:35写道: > Hi Shuiqiang, > > Thanks for driving this. Big +1 for supporting D

Re: [DISCUSS] FLIP-130: Support for Python DataStream API (Stateless Part)

2020-07-08 Thread Wei Zhong
Hi Shuiqiang, Thanks for driving this. Big +1 for supporting DataStream API in PyFlink! Best, Wei > 在 2020年7月9日,10:29,Hequn Cheng 写道: > > +1 for adding the Python DataStream API and starting with the stateless > part. > There are already some users that expressed their wish to have the Python

Re: [DISCUSS] FLIP-130: Support for Python DataStream API (Stateless Part)

2020-07-08 Thread Hequn Cheng
+1 for adding the Python DataStream API and starting with the stateless part. There are already some users that expressed their wish to have the Python DataStream APIs. Once we have the APIs in PyFlink, we can cover more use cases for our users. Best, Hequn On Wed, Jul 8, 2020 at 11:45 AM Shuiqia

[jira] [Created] (FLINK-18534) KafkaTableITCase.testKafkaDebeziumChangelogSource failed with "Topic 'changelog_topic' already exists"

2020-07-08 Thread Dian Fu (Jira)
Dian Fu created FLINK-18534: --- Summary: KafkaTableITCase.testKafkaDebeziumChangelogSource failed with "Topic 'changelog_topic' already exists" Key: FLINK-18534 URL: https://issues.apache.org/jira/browse/FLINK-18534

Re: [ANNOUNCE] New PMC member: Piotr Nowojski

2020-07-08 Thread Xingcan Cui
Congratulations, Piotr! Best, Xingcan On Wed, Jul 8, 2020, 21:53 Yang Wang wrote: > Congratulations Piotr! > > > Best, > Yang > > Dan Zou 于2020年7月8日周三 下午10:36写道: > > > Congratulations! > > > > Best, > > Dan Zou > > > > > 2020年7月8日 下午5:25,godfrey he 写道: > > > > > > Congratulations > > > > >

[jira] [Created] (FLINK-18533) AccumulatorLiveITCase.testStreaming hangs

2020-07-08 Thread Dian Fu (Jira)
Dian Fu created FLINK-18533: --- Summary: AccumulatorLiveITCase.testStreaming hangs Key: FLINK-18533 URL: https://issues.apache.org/jira/browse/FLINK-18533 Project: Flink Issue Type: Test Co

Re: [ANNOUNCE] New PMC member: Piotr Nowojski

2020-07-08 Thread Yang Wang
Congratulations Piotr! Best, Yang Dan Zou 于2020年7月8日周三 下午10:36写道: > Congratulations! > > Best, > Dan Zou > > > 2020年7月8日 下午5:25,godfrey he 写道: > > > > Congratulations > >

[jira] [Created] (FLINK-18532) Remove Beta tag from MATCH_RECOGNIZE docs

2020-07-08 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-18532: Summary: Remove Beta tag from MATCH_RECOGNIZE docs Key: FLINK-18532 URL: https://issues.apache.org/jira/browse/FLINK-18532 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-18531) Minicluster option to reuse same port if 0 is applied

2020-07-08 Thread David Chen (Jira)
David Chen created FLINK-18531: -- Summary: Minicluster option to reuse same port if 0 is applied Key: FLINK-18531 URL: https://issues.apache.org/jira/browse/FLINK-18531 Project: Flink Issue Type:

Re: [ANNOUNCE] New PMC member: Piotr Nowojski

2020-07-08 Thread Dan Zou
Congratulations! Best, Dan Zou > 2020年7月8日 下午5:25,godfrey he 写道: > > Congratulations

[jira] [Created] (FLINK-18530) ParquetAvroWriters can not write data to hdfs

2020-07-08 Thread humengyu (Jira)
humengyu created FLINK-18530: Summary: ParquetAvroWriters can not write data to hdfs Key: FLINK-18530 URL: https://issues.apache.org/jira/browse/FLINK-18530 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-18529) Query Hive table and filter by timestamp partition doesn't work

2020-07-08 Thread Rui Li (Jira)
Rui Li created FLINK-18529: -- Summary: Query Hive table and filter by timestamp partition doesn't work Key: FLINK-18529 URL: https://issues.apache.org/jira/browse/FLINK-18529 Project: Flink Issue Ty

[jira] [Created] (FLINK-18528) Update UNNEST to new type system

2020-07-08 Thread Timo Walther (Jira)
Timo Walther created FLINK-18528: Summary: Update UNNEST to new type system Key: FLINK-18528 URL: https://issues.apache.org/jira/browse/FLINK-18528 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-18527) Task Managers fail to start on HDP 2.6.5 due to commons-cli conflict

2020-07-08 Thread Truong Duc Kien (Jira)
Truong Duc Kien created FLINK-18527: --- Summary: Task Managers fail to start on HDP 2.6.5 due to commons-cli conflict Key: FLINK-18527 URL: https://issues.apache.org/jira/browse/FLINK-18527 Project:

Re: [ANNOUNCE] New PMC member: Piotr Nowojski

2020-07-08 Thread godfrey he
Congratulations Piotr! Best, Godfrey Yun Tang 于2020年7月8日周三 下午5:22写道: > Congratulations, Piotr! > > Best > Yun Tang > > From: Danny Chan > Sent: Wednesday, July 8, 2020 15:46 > To: dev@flink.apache.org > Subject: Re: [ANNOUNCE] New PMC member: Piotr Nowojski >

Re: [ANNOUNCE] New PMC member: Piotr Nowojski

2020-07-08 Thread Yun Tang
Congratulations, Piotr! Best Yun Tang From: Danny Chan Sent: Wednesday, July 8, 2020 15:46 To: dev@flink.apache.org Subject: Re: [ANNOUNCE] New PMC member: Piotr Nowojski Congratulations and nice work Piotr ~ Best, Danny Chan 在 2020年7月7日 +0800 PM10:00,dev@flink

[jira] [Created] (FLINK-18526) Add the configuration of Python UDF using Managed Memory in the doc of Pyflink

2020-07-08 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-18526: Summary: Add the configuration of Python UDF using Managed Memory in the doc of Pyflink Key: FLINK-18526 URL: https://issues.apache.org/jira/browse/FLINK-18526 Projec

[jira] [Created] (FLINK-18525) Running yarn-session.sh occurs error

2020-07-08 Thread zhangyunyun (Jira)
zhangyunyun created FLINK-18525: --- Summary: Running yarn-session.sh occurs error Key: FLINK-18525 URL: https://issues.apache.org/jira/browse/FLINK-18525 Project: Flink Issue Type: Bug

Why ApplicationMode for k8s doesn't support using remote jar?

2020-07-08 Thread DashShen
Hi, When I use ApplicationMode on k8s to submit a new flink application, it's not capable for me to using remote jar like what yarn does and I have to pack the jar into the image before. So I want know why the application mode for k8s doesn't support to reading remote jar. -- Sent from: http://

Re: [ANNOUNCE] Apache Flink 1.11.0 released

2020-07-08 Thread godfrey he
Congratulations! Thanks Zhijiang and Piotr for the great work, and thanks everyone for their contribution! Best, Godfrey Benchao Li 于2020年7月8日周三 下午12:39写道: > Congratulations! Thanks Zhijiang & Piotr for the great work as release > managers. > > Rui Li 于2020年7月8日周三 上午11:38写道: > >> Congratulat

[jira] [Created] (FLINK-18524) Scala varargs cause exception for new inference

2020-07-08 Thread Timo Walther (Jira)
Timo Walther created FLINK-18524: Summary: Scala varargs cause exception for new inference Key: FLINK-18524 URL: https://issues.apache.org/jira/browse/FLINK-18524 Project: Flink Issue Type: S

Re: [ANNOUNCE] New PMC member: Piotr Nowojski

2020-07-08 Thread Danny Chan
Congratulations and nice work Piotr ~ Best, Danny Chan 在 2020年7月7日 +0800 PM10:00,dev@flink.apache.org,写道: > > Congratulations!

Re: [ANNOUNCE] Apache Flink 1.11.0 released

2020-07-08 Thread Congxian Qiu
Thanks Zhijiang and Piotr for the great work as release manager, and thanks everyone who makes the release possible! Best, Congxian Benchao Li 于2020年7月8日周三 下午12:39写道: > Congratulations! Thanks Zhijiang & Piotr for the great work as release > managers. > > Rui Li 于2020年7月8日周三 上午11:38写道: > >>

[jira] [Created] (FLINK-18523) The watermark could be updated without data for some time

2020-07-08 Thread chen yong (Jira)
chen yong created FLINK-18523: - Summary: The watermark could be updated without data for some time Key: FLINK-18523 URL: https://issues.apache.org/jira/browse/FLINK-18523 Project: Flink Issue Typ