Re: [DISCUSS] Releasing Flink 1.13.6

2022-01-25 Thread Jing Zhang
+1 for releasing Flink 1.13.6 Thanks Martijn and Konstantin for driving this. Best, Jing Zhang David Morávek 于2022年1月25日周二 19:13写道: > Thanks for driving this Martijn, +1 for the release > > Also big thanks to Konstantin for volunteering > > Best, > D. > > On Mon, Jan 24, 2022 at 3:24 PM Till R

Re: [DISCUSS] FLIP-212: Introduce Flink Kubernetes Operator

2022-01-25 Thread Yang Wang
Thanks Thomas for creating FLIP-212 to introduce the Flink Kubernetes Operator. The proposal looks already very good to me and has integrated all the input in the previous discussion(e.g. native K8s VS standalone, Go VS java). I read the FLIP carefully and have some questions that need to be clar

Re: PR Review Request

2022-01-25 Thread Jing Zhang
Please ignore me. I originally wanted to send it to calcite's dev mail list, but I sent it to the wrong mail list. I'm terribly sorry.😥 Jing Zhang 于2022年1月26日周三 14:55写道: > Hi community, > My apologies for interrupting. > Anyone could help to review the pr > https://github.com/apache/calcite/pull

PR Review Request

2022-01-25 Thread Jing Zhang
Hi community, My apologies for interrupting. Anyone could help to review the pr https://github.com/apache/calcite/pull/2606? Thanks a lot. CALCITE-4865 is the first sub-task of CALCITE-4864. This Jira aims to extend existing Table function in order to support Polymorphic Table Function which is in

Re: [DISCUSS] Pushing Apache Flink 1.15 Feature Freeze

2022-01-25 Thread Yuan Mei
+1 extending feature freeze for one week. Code Freeze on 6th (end of Spring Festival) is equivalent to say code freeze at the end of this week for Chinese buddies, since Spring Festival starts next week. It also means they should be partially available during the holiday, otherwise they would bloc

[jira] [Created] (FLINK-25816) Changelog keyed state backend would come across NPE during notification

2022-01-25 Thread Yun Tang (Jira)
Yun Tang created FLINK-25816: Summary: Changelog keyed state backend would come across NPE during notification Key: FLINK-25816 URL: https://issues.apache.org/jira/browse/FLINK-25816 Project: Flink

[jira] [Created] (FLINK-25815) PulsarSourceITCase.testTaskManagerFailure failed on azure due to timeout

2022-01-25 Thread Yun Gao (Jira)
Yun Gao created FLINK-25815: --- Summary: PulsarSourceITCase.testTaskManagerFailure failed on azure due to timeout Key: FLINK-25815 URL: https://issues.apache.org/jira/browse/FLINK-25815 Project: Flink

Re: [DISCUSS] Pushing Apache Flink 1.15 Feature Freeze

2022-01-25 Thread Yun Tang
Since the official Spring Festival holidays in China starts from Jan 31th to Feb 6th, and many developers in China would enjoy the holidays at that time. +1 for extending the feature freeze. Best Yun Tang From: Jingsong Li Sent: Wednesday, January 26, 2022 10:32

[jira] [Created] (FLINK-25814) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond failed due to stop-with-savepoint failed

2022-01-25 Thread Yun Gao (Jira)
Yun Gao created FLINK-25814: --- Summary: AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond failed due to stop-with-savepoint failed Key: FLINK-25814 URL: https://issues.apache.org/jira/brow

[jira] [Created] (FLINK-25813) TableITCase.testCollectWithClose failed on azure

2022-01-25 Thread Yun Gao (Jira)
Yun Gao created FLINK-25813: --- Summary: TableITCase.testCollectWithClose failed on azure Key: FLINK-25813 URL: https://issues.apache.org/jira/browse/FLINK-25813 Project: Flink Issue Type: Bug

Re: [DISCUSS] Future of Per-Job Mode

2022-01-25 Thread Yang Wang
Hi all, I remember the application mode was initially named "cluster mode". As a contrast, the per-job mode is the "client mode". So I believe application mode should cover all the functionalities of per-job except where we are running the user main code. In the containerized or the Kubernetes wor

Re: [DISCUSS] Pushing Apache Flink 1.15 Feature Freeze

2022-01-25 Thread Jingsong Li
+1 for extending the feature freeze. Thanks Joe for driving. Best, Jingsong On Wed, Jan 26, 2022 at 12:04 AM Martijn Visser wrote: > > Hi all, > > +1 for extending the feature freeze. We could use the time to try to wrap > up some important SQL related features and improvements. > > Best regard

Re: Re: Re: [VOTE] FLIP-204: Introduce Hash Lookup Join

2022-01-25 Thread Lincoln Lee
+1 (non-binding) Thanks Jing! Best, Lincoln Lee Terry 于2022年1月25日周二 17:51写道: > +1 (non-binding) > Thanks for driving this. > > Best regards > > zhangmang1 于2022年1月25日周二 10:39写道: > > > +1 >

[jira] [Created] (FLINK-25812) Show Plan in Ui doesn't show.

2022-01-25 Thread None none (Jira)
None none created FLINK-25812: - Summary: Show Plan in Ui doesn't show. Key: FLINK-25812 URL: https://issues.apache.org/jira/browse/FLINK-25812 Project: Flink Issue Type: Bug Components:

[VOTE] Apache Flink Stateful Functions 3.2.0, release candidate #1

2022-01-25 Thread Till Rohrmann
Hi everyone, Please review and vote on the release candidate #1 for the version 3.2.0 of Apache Flink Stateful Functions, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) **Release Overview** As an overview, the release consists of th

[jira] [Created] (FLINK-25811) Fix generic AsyncSinkWriter retrying requests in reverse order

2022-01-25 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-25811: --- Summary: Fix generic AsyncSinkWriter retrying requests in reverse order Key: FLINK-25811 URL: https://issues.apache.org/jira/browse/FLINK-25811 Project: Flink

[jira] [Created] (FLINK-25810) [FLIP-171] Add Uber-jar for sql connector for KinesisDataStreams.

2022-01-25 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-25810: --- Summary: [FLIP-171] Add Uber-jar for sql connector for KinesisDataStreams. Key: FLINK-25810 URL: https://issues.apache.org/jira/browse/FLINK-25810 Project: Flink

Re: [DISCUSS] Pushing Apache Flink 1.15 Feature Freeze

2022-01-25 Thread Martijn Visser
Hi all, +1 for extending the feature freeze. We could use the time to try to wrap up some important SQL related features and improvements. Best regards, Martijn On Tue, 25 Jan 2022 at 16:38, Johannes Moser wrote: > Dear Flink community, > > as mentioned in the summary mail earlier some contri

[jira] [Created] (FLINK-25809) Introduce test infra for building FLIP-190 tests

2022-01-25 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-25809: --- Summary: Introduce test infra for building FLIP-190 tests Key: FLINK-25809 URL: https://issues.apache.org/jira/browse/FLINK-25809 Project: Flink

[DISCUSS] Pushing Apache Flink 1.15 Feature Freeze

2022-01-25 Thread Johannes Moser
Dear Flink community, as mentioned in the summary mail earlier some contributors voiced that they would benefit from pushing the feature freeze for 1.15. by a week. This would mean Monday, 14th of February 2022, end of business CEST. Please let us know in case you got any concerns. Best, Ti

Flink 1.15. Bi-weekly 2022-01-25

2022-01-25 Thread Johannes Moser
Dear Flink community, Today we had another bi-weekly for the Apache Flink 1.15 release. The planned feature freeze is just 2 weeks in. In the last two weeks there some progress and some features have been moved to “done”. We are now at 70 % according to the assessments of the responsible ICs.

[jira] [Created] (FLINK-25808) JsonTypeInfo property should be valid java identifier

2022-01-25 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-25808: Summary: JsonTypeInfo property should be valid java identifier Key: FLINK-25808 URL: https://issues.apache.org/jira/browse/FLINK-25808 Project: Flink

Re: [DISCUSS] Stateful Functions 3.2.0 release?

2022-01-25 Thread Till Rohrmann
Quick update: Igal has resolved the last outstanding ticket [1]. [1] https://issues.apache.org/jira/browse/FLINK-25775 Cheers, Till On Tue, Jan 25, 2022 at 9:56 AM Till Rohrmann wrote: > Thanks everyone. I will start creating the artifacts. > > Cheers, > Till > > On Mon, Jan 24, 2022 at 9:13 P

Re: [DISCUSS] Host StatefulFunction JavaScript SDK on npm

2022-01-25 Thread Till Rohrmann
Alright, I hope that we could resolve all mentioned concerns. If not, then please speak up. I will try to set up a npm account for the Flink project. Cheers, Till On Mon, Jan 24, 2022 at 4:40 PM Till Rohrmann wrote: > Reading the description of the ticket again, I think the comment might > also

[jira] [Created] (FLINK-25807) Generated SubtaskExecutionAttemptDetailsInfo contains duplicate property

2022-01-25 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-25807: Summary: Generated SubtaskExecutionAttemptDetailsInfo contains duplicate property Key: FLINK-25807 URL: https://issues.apache.org/jira/browse/FLINK-25807 Proj

[jira] [Created] (FLINK-25806) Remove legacy high availability services

2022-01-25 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-25806: - Summary: Remove legacy high availability services Key: FLINK-25806 URL: https://issues.apache.org/jira/browse/FLINK-25806 Project: Flink Issue Type: Improv

RE: [DISCUSS] Future of Per-Job Mode

2022-01-25 Thread Ferenc Csaky
Hi Konstantin, First of all, sorry for the delay. We at Cloudera are currently relying on per-job mode deploying Flink applications over YARN. Specifically, we allow users to upload connector jars and other artifacts. There are also some default jars that we need to ship. These are all stored o

Re: [DISCUSS] Releasing Flink 1.13.6

2022-01-25 Thread David Morávek
Thanks for driving this Martijn, +1 for the release Also big thanks to Konstantin for volunteering Best, D. On Mon, Jan 24, 2022 at 3:24 PM Till Rohrmann wrote: > +1 for the 1.13.6 release and thanks for volunteering Konstantin. > > Cheers, > Till > > On Mon, Jan 24, 2022 at 2:57 PM Konstantin

[jira] [Created] (FLINK-25805) Use compact DataType serialization for default classes instead of internal ones

2022-01-25 Thread Timo Walther (Jira)
Timo Walther created FLINK-25805: Summary: Use compact DataType serialization for default classes instead of internal ones Key: FLINK-25805 URL: https://issues.apache.org/jira/browse/FLINK-25805 Proje

Re: [DISCUSS] FLIP-211: Kerberos delegation token framework

2022-01-25 Thread Gabor Somogyi
First of all thanks for investing your time and helping me out. As I see you have pretty solid knowledge in the RPC area. I would like to rely on your knowledge since I'm learning this part. > - Do we need to introduce a new RPC method or can we for example piggyback on heartbeats? I'm fine with

[jira] [Created] (FLINK-25804) Loading and running connector code use separated ClassLoader.

2022-01-25 Thread Ada Wong (Jira)
Ada Wong created FLINK-25804: Summary: Loading and running connector code use separated ClassLoader. Key: FLINK-25804 URL: https://issues.apache.org/jira/browse/FLINK-25804 Project: Flink Issue

Re: Re: Re: [VOTE] FLIP-204: Introduce Hash Lookup Join

2022-01-25 Thread Terry
+1 (non-binding) Thanks for driving this. Best regards zhangmang1 于2022年1月25日周二 10:39写道: > +1

Re: [DISCUSS] Stateful Functions 3.2.0 release?

2022-01-25 Thread Till Rohrmann
Thanks everyone. I will start creating the artifacts. Cheers, Till On Mon, Jan 24, 2022 at 9:13 PM Tzu-Li (Gordon) Tai wrote: > +1 > > On Mon, Jan 24, 2022 at 9:43 AM Igal Shilman wrote: > > > +1 and thanks for volunteering to be the release manager! > > > > Cheers, > > Igal. > > > > On Mon, J

[jira] [Created] (FLINK-25803) Implement partition and bucket filter of FileStoreScanImpl

2022-01-25 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-25803: --- Summary: Implement partition and bucket filter of FileStoreScanImpl Key: FLINK-25803 URL: https://issues.apache.org/jira/browse/FLINK-25803 Project: Flink Issu