[jira] [Created] (FLINK-18671) Update upgrade compatibility table (docs/ops/upgrading.md) for 1.11.0

2020-07-22 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-18671: -- Summary: Update upgrade compatibility table (docs/ops/upgrading.md) for 1.11.0 Key: FLINK-18671 URL: https://issues.apache.org/jira/browse/FLINK-18671 Project:

Re: [ANNOUNCE] Apache Flink 1.11.1 released

2020-07-22 Thread Till Rohrmann
Thanks for being the release manager for the 1.11.1 release, Dian. Thanks a lot to everyone who contributed to this release. Cheers, Till On Wed, Jul 22, 2020 at 11:38 AM Hequn Cheng wrote: > Thanks Dian for the great work and thanks to everyone who makes this > release possible! > > Best,

[jira] [Created] (FLINK-18670) Add (statefun-)docker repos to community page

2020-07-22 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-18670: Summary: Add (statefun-)docker repos to community page Key: FLINK-18670 URL: https://issues.apache.org/jira/browse/FLINK-18670 Project: Flink Issue

[DISCUSS] Planning Flink 1.12

2020-07-22 Thread Robert Metzger
Hi all, Now that the 1.11 release is out, it is time to plan for the next major Flink release. Some items: 1. Dian Fu and me volunteer to be the release managers for Flink 1.12. 1. Timeline: We propose to stick to our approximate 4 month release cycle, thus the release

[jira] [Created] (FLINK-18672) Fix Scala code examples for UDF type inference annotations

2020-07-22 Thread Fabian Hueske (Jira)
Fabian Hueske created FLINK-18672: - Summary: Fix Scala code examples for UDF type inference annotations Key: FLINK-18672 URL: https://issues.apache.org/jira/browse/FLINK-18672 Project: Flink

Re: [ANNOUNCE] Apache Flink 1.11.1 released

2020-07-22 Thread Konstantin Knauf
Thank you for managing the quick follow up release. I think this was very important for Table & SQL users. On Wed, Jul 22, 2020 at 1:45 PM Till Rohrmann wrote: > Thanks for being the release manager for the 1.11.1 release, Dian. Thanks > a lot to everyone who contributed to this release. > >

Re: [REMINDER] Use 'starter' labels for Jira issues where it makes sense

2020-07-22 Thread Yu Li
Thanks for the reminder Andrey. Issues with the 'starter' label are indeed helpful for new contributors to join the project. Best Regards, Yu On Wed, 22 Jul 2020 at 14:30, Till Rohrmann wrote: > Thanks for the reminder Andrey. This is important for helping new > contributors to find their way

Re: [REMINDER] Use 'starter' labels for Jira issues where it makes sense

2020-07-22 Thread Till Rohrmann
Thanks for the reminder Andrey. This is important for helping new contributors to find their way around in the Flink project. Cheers, Till On Mon, Jul 20, 2020 at 5:30 PM Aljoscha Krettek wrote: > Yes, thanks Andrey! That's a good reminder for everyone. :-) > > On 20.07.20 16:02, Andrey

Re: [ANNOUNCE] Apache Flink 1.11.1 released

2020-07-22 Thread Leonard Xu
Congratulations! Thanks Dian Fu for the great work as release manager, and thanks everyone involved! Best Leonard Xu > 在 2020年7月22日,14:52,Dian Fu 写道: > > The Apache Flink community is very happy to announce the release of Apache > Flink 1.11.1, which is the first bugfix release for the

Re: [ANNOUNCE] Apache Flink 1.11.1 released

2020-07-22 Thread Yangze Guo
Congrats! Thanks Dian Fu for being release manager, and everyone involved! Best, Yangze Guo On Wed, Jul 22, 2020 at 3:14 PM Wei Zhong wrote: > > Congratulations! Thanks Dian for the great work! > > Best, > Wei > > > 在 2020年7月22日,15:09,Leonard Xu 写道: > > > > Congratulations! > > > > Thanks

Re: [ANNOUNCE] Apache Flink 1.11.1 released

2020-07-22 Thread Jark Wu
Congratulations! Thanks Dian for the great work and to be the release manager! Best, Jark On Wed, 22 Jul 2020 at 15:45, Yangze Guo wrote: > Congrats! > > Thanks Dian Fu for being release manager, and everyone involved! > > Best, > Yangze Guo > > On Wed, Jul 22, 2020 at 3:14 PM Wei Zhong

Re: [DISCUSS] FLIP-36 - Support Interactive Programming in Flink Table API

2020-07-22 Thread Kurt Young
Thanks for the reply, I have one more comment about the optimizer affection. Even if you are trying to make the cached table be as orthogonal to the optimizer as possible by introducing a special sink, it is still not clear why this approach is safe. Maybe you can add some process introduction

[DISCUSS] Adding Azure Platform Support in DataStream, Table and SQL Connectors

2020-07-22 Thread Israel Ekpo
I have opened the following issues to track new efforts to bring additional Azure Support in the following areas to the connectors ecosystem. My goal is to add the first two features [FLINK-18562] and [FLINK-18568] to the existing file system capabilities [1] and then have the other connectors

Re: thrift support

2020-07-22 Thread Chen Qin
Thanks, Yu sharing more background on this. Jark, We were able to sync with Yu a bit offline. I think we should reuse Jira and the future on how to reuse code when we get into the implementation phase. and continue the discussion maybe share a google doc detail list of work and options so folks

[jira] [Created] (FLINK-18668) BytesHashMap#growAndRehash should release newly allocated segments before throwing the exception

2020-07-22 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-18668: --- Summary: BytesHashMap#growAndRehash should release newly allocated segments before throwing the exception Key: FLINK-18668 URL: https://issues.apache.org/jira/browse/FLINK-18668

[ANNOUNCE] Apache Flink 1.11.1 released

2020-07-22 Thread Dian Fu
The Apache Flink community is very happy to announce the release of Apache Flink 1.11.1, which is the first bugfix release for the Apache Flink 1.11 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data

Re: [ANNOUNCE] New PMC member: Piotr Nowojski

2020-07-22 Thread Forward Xu
Congratulations! Best, Forward godfrey he 于2020年7月22日周三 上午10:45写道: > Congratulations! > > Best, > Godfrey > > Till Rohrmann 于2020年7月21日周二 下午10:46写道: > > > Congrats, Piotr! > > > > Cheers, > > Till > > > > On Thu, Jul 9, 2020 at 4:15 AM Xingcan Cui wrote: > > > > > Congratulations, Piotr! >

Re: [ANNOUNCE] Apache Flink 1.11.1 released

2020-07-22 Thread Hequn Cheng
Thanks Dian for the great work and thanks to everyone who makes this release possible! Best, Hequn On Wed, Jul 22, 2020 at 4:40 PM Jark Wu wrote: > Congratulations! Thanks Dian for the great work and to be the release > manager! > > Best, > Jark > > On Wed, 22 Jul 2020 at 15:45, Yangze Guo

Re: [DISCUSS] FLIP-36 - Support Interactive Programming in Flink Table API

2020-07-22 Thread Xuannan Su
Hi Kurt, Thanks for the comments. 1. How do you identify the CachedTable? For the current design proposed in FLIP-36, we are using the first approach you mentioned, where the key of the map is the Cached Table java object. I think it is fine not to be able to identify another table

Re: [ANNOUNCE] Apache Flink 1.11.1 released

2020-07-22 Thread Wei Zhong
Congratulations! Thanks Dian for the great work! Best, Wei > 在 2020年7月22日,15:09,Leonard Xu 写道: > > Congratulations! > > Thanks Dian Fu for the great work as release manager, and thanks everyone > involved! > > Best > Leonard Xu > >> 在 2020年7月22日,14:52,Dian Fu 写道: >> >> The Apache Flink

[jira] [Created] (FLINK-18669) Remove testing-related code from production code in PubSub connector

2020-07-22 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-18669: -- Summary: Remove testing-related code from production code in PubSub connector Key: FLINK-18669 URL: https://issues.apache.org/jira/browse/FLINK-18669 Project:

[jira] [Created] (FLINK-18673) Calling ROW() in a UDF results in UnsupportedOperationException

2020-07-22 Thread Fabian Hueske (Jira)
Fabian Hueske created FLINK-18673: - Summary: Calling ROW() in a UDF results in UnsupportedOperationException Key: FLINK-18673 URL: https://issues.apache.org/jira/browse/FLINK-18673 Project: Flink

Re: [ANNOUNCE] Apache Flink 1.11.1 released

2020-07-22 Thread Rui Li
Thanks Dian for the great work! On Thu, Jul 23, 2020 at 10:22 AM Jingsong Li wrote: > Thanks for being the release manager for the 1.11.1 release, Dian. > > Best, > Jingsong > > On Thu, Jul 23, 2020 at 10:12 AM Zhijiang > wrote: > >> Thanks for being the release manager and the efficient work,

Re: [DISCUSS] Planning Flink 1.12

2020-07-22 Thread Harold.Miao
I'm excited to hear about this feature, very, very, very highly encouraged Prasanna kumar 于2020年7月23日周四 上午12:10写道: > Hi Flink Dev Team, > > Dynamic AutoScaling Based on the incoming data load would be a great > feature. > > We should be able have some rule say If the load increased by 20% ,

Re: [DISCUSS] Planning Flink 1.12

2020-07-22 Thread Canbin Zheng
Hi All, Thanks for bring-up this discussion, Robert! Congratulations on becoming the release manager of 1.12, Dian and Robert ! -- Here are some of my thoughts of the features for native integration with Kubernetes in Flink 1.12: 1. Support user-specified pod templates Description:

Re: [ANNOUNCE] Apache Flink 1.11.1 released

2020-07-22 Thread Zhijiang
Thanks for being the release manager and the efficient work, Dian! Best, Zhijiang -- From:Konstantin Knauf Send Time:2020年7月22日(星期三) 19:55 To:Till Rohrmann Cc:dev ; Yangze Guo ; Dian Fu ; user ; user-zh Subject:Re: [ANNOUNCE]

Re: [ANNOUNCE] Apache Flink 1.11.1 released

2020-07-22 Thread Congxian Qiu
Thanks Dian for the great work and thanks to everyone who makes this release possible! Best, Congxian Rui Li 于2020年7月23日周四 上午10:48写道: > Thanks Dian for the great work! > > On Thu, Jul 23, 2020 at 10:22 AM Jingsong Li > wrote: > > > Thanks for being the release manager for the 1.11.1 release,

[jira] [Created] (FLINK-18679) It doesn't support to join two tables containing the same field names in Table API

2020-07-22 Thread Dian Fu (Jira)
Dian Fu created FLINK-18679: --- Summary: It doesn't support to join two tables containing the same field names in Table API Key: FLINK-18679 URL: https://issues.apache.org/jira/browse/FLINK-18679 Project:

Re: [ANNOUNCE] Apache Flink 1.11.1 released

2020-07-22 Thread Jingsong Li
Thanks for being the release manager for the 1.11.1 release, Dian. Best, Jingsong On Thu, Jul 23, 2020 at 10:12 AM Zhijiang wrote: > Thanks for being the release manager and the efficient work, Dian! > > Best, > Zhijiang > > -- >

Re: [DISCUSS] Planning Flink 1.12

2020-07-22 Thread jincheng sun
Hi All, Thanks for bring-up this discussion, Robert! Congratulations on becoming the release manager of 1.12, Dian and Robert ! -- Here is my thoughts of the features for PyFlink in Flink 1.12: 1. Improve the usabilities for PyFlink Description: Improve the usabilities for

Re: [DISCUSS] Planning Flink 1.12

2020-07-22 Thread Dian Fu
Thanks Robert for bringing up this discussion. This is very important to ensure that we have a smooth release process as there are only two months left before feature freeze. It would be good to have a list of the features for 1.12 as soon as possible. Welcome any one to post the feature list

[jira] [Created] (FLINK-18678) Hive connector fails to create vector orc reader if user specifies incorrect hive version

2020-07-22 Thread Rui Li (Jira)
Rui Li created FLINK-18678: -- Summary: Hive connector fails to create vector orc reader if user specifies incorrect hive version Key: FLINK-18678 URL: https://issues.apache.org/jira/browse/FLINK-18678

[jira] [Created] (FLINK-18677) ZooKeeperLeaderRetrievalService does not invalidate leader in case of SUSPENDED connection

2020-07-22 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-18677: - Summary: ZooKeeperLeaderRetrievalService does not invalidate leader in case of SUSPENDED connection Key: FLINK-18677 URL: https://issues.apache.org/jira/browse/FLINK-18677

Re: [DISCUSS] Planning Flink 1.12

2020-07-22 Thread Prasanna kumar
Hi Flink Dev Team, Dynamic AutoScaling Based on the incoming data load would be a great feature. We should be able have some rule say If the load increased by 20% , add extra resource should be added. Or time based say during these peak hours the pipeline should scale automatically by 50%. This

[jira] [Created] (FLINK-18675) Checkpoint not maintaining minimum pause duration between checkpoints

2020-07-22 Thread Ravi Bhushan Ratnakar (Jira)
Ravi Bhushan Ratnakar created FLINK-18675: - Summary: Checkpoint not maintaining minimum pause duration between checkpoints Key: FLINK-18675 URL: https://issues.apache.org/jira/browse/FLINK-18675

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

2020-07-22 Thread Jark Wu
Hi all, After some offline discussion with other people, I'm also fine with using the builder pattern now, even though I still think the `.build()` method is a little verbose in the user code. I have updated the FLIP with following changes: 1) use builder pattern instead of "new" keyword. In

[jira] [Created] (FLINK-18674) Support to bridge Transformation (DataStream) with FLIP-95 interface?

2020-07-22 Thread Jark Wu (Jira)
Jark Wu created FLINK-18674: --- Summary: Support to bridge Transformation (DataStream) with FLIP-95 interface? Key: FLINK-18674 URL: https://issues.apache.org/jira/browse/FLINK-18674 Project: Flink

[jira] [Created] (FLINK-18676) Update version of aws to support use of default constructor of "WebIdentityTokenCredentialsProvider"

2020-07-22 Thread Ravi Bhushan Ratnakar (Jira)
Ravi Bhushan Ratnakar created FLINK-18676: - Summary: Update version of aws to support use of default constructor of "WebIdentityTokenCredentialsProvider" Key: FLINK-18676 URL: