[jira] [Created] (FLINK-31877) StreamExecutionEnvironmentTests.test_from_collection_with_data_types is unstable

2023-04-20 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-31877: --- Summary: StreamExecutionEnvironmentTests.test_from_collection_with_data_types is unstable Key: FLINK-31877 URL: https://issues.apache.org/jira/browse/FLINK-31877

[jira] [Created] (FLINK-31876) [JUnit5 Migration] Module: flink-queryable-state

2023-04-20 Thread Yanfei Lei (Jira)
Yanfei Lei created FLINK-31876: -- Summary: [JUnit5 Migration] Module: flink-queryable-state Key: FLINK-31876 URL: https://issues.apache.org/jira/browse/FLINK-31876 Project: Flink Issue Type:

Re: DefaultInputSplitAssigner question

2023-04-20 Thread Zhu Zhu
Sure I will take a look. Thanks, Zhu Péter Váry 于2023年4月20日周四 22:58写道: > > Created a PR for the change: https://github.com/apache/flink/pull/22437 > Could you please review Zhu? > > Thanks, > Peter > > Péter Váry ezt írta (időpont: 2023. ápr. 20., > Cs, 13:54): > > > Thanks Zhu for the quick

Re: [VOTE] FLIP-304: Pluggable Failure Enrichers

2023-04-20 Thread Zhu Zhu
+1 (binding) Thanks, Zhu Anton Kalashnikov 于2023年4月20日周四 20:03写道: > > +1 (binding) > > > Thanks for this FLIP Panos, LGTM. > > -- > Best regards, > Anton Kalashnikov > > On 20.04.23 13:44, Roman Khachatryan wrote: > > +1 (binding) > > > > The FLIP LGTM, thanks Panos! > > > > Regards, > > Roman

[jira] [Created] (FLINK-31875) OSS throwns NoClassDefFoundError due to old hadoop-common version

2023-04-20 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-31875: Summary: OSS throwns NoClassDefFoundError due to old hadoop-common version Key: FLINK-31875 URL: https://issues.apache.org/jira/browse/FLINK-31875 Project: Flink

[jira] [Created] (FLINK-31874) Support truncate table statement in batch mode

2023-04-20 Thread luoyuxia (Jira)
luoyuxia created FLINK-31874: Summary: Support truncate table statement in batch mode Key: FLINK-31874 URL: https://issues.apache.org/jira/browse/FLINK-31874 Project: Flink Issue Type: New

Re: [VOTE] FLIP-302: Support TRUNCATE TABLE statement in batch mode

2023-04-20 Thread yuxia
Hi, all. FLIP-302 [1] has been accepted. There are 3 binding votes, 5 non-binding votes: - Lincoln (binding) - Jingsong Li (binding) - Benchao Li (binding) - Ron (non-binding) - Jacky Lau (non-binding) - Shammon FY (non-binding) - Hang (non-binding) - Aitozi (non-binding) Thanks everyone. [1]

Re: [VOTE] Release flink-connector-kafka 3.0.0 for Flink 1.17, release candidate #2

2023-04-20 Thread Tzu-Li (Gordon) Tai
We have unanimously approved this release. There are 6 approving votes, 3 of which are binding: * Alexander Sorokoumov * Martijn Visser (binding) * Tzu-Li (Gordon) Tai (binding) * Danny Cranmer (binding) * Ahmed Hamdy * Mason Chen Thanks so much everyone for testing and voting! I will now

Re: [VOTE] Release flink-connector-kafka 3.0.0 for Flink 1.17, release candidate #2

2023-04-20 Thread Mason Chen
+1 (non-binding) * Verified hashes and signatures * Verified no binaries * Verified LICENSE and NOTICE files, pointing to 2023 as well * Verified poms point to 3.0.0 * Reviewed web PR * Built from source * Verified git tag Best, Mason On Thu, Apr 20, 2023 at 10:04 AM Ahmed Hamdy wrote: > +1

[jira] [Created] (FLINK-31873) Add setMaxParallelism to the DataStreamSink Class

2023-04-20 Thread Eric Xiao (Jira)
Eric Xiao created FLINK-31873: - Summary: Add setMaxParallelism to the DataStreamSink Class Key: FLINK-31873 URL: https://issues.apache.org/jira/browse/FLINK-31873 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31872) CLONE - AsyncSinkWriter Performance regression due to AIMD rate limiting strategy

2023-04-20 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-31872: --- Summary: CLONE - AsyncSinkWriter Performance regression due to AIMD rate limiting strategy Key: FLINK-31872 URL: https://issues.apache.org/jira/browse/FLINK-31872

Re: [VOTE] Release flink-connector-elasticsearch, release candidate #1

2023-04-20 Thread Ahmed Hamdy
+ (non-binding) - Verified signature and hashes are correct. - Verified there are no binaries in the source archive - Verified tag in github - reviewed and approved web PR - build source successfully Best Regards Ahmed On Thu, 20 Apr 2023 at 16:50, Danny Cranmer wrote: > +1 (binding) > > -

Re: [VOTE] Release flink-connector-kafka 3.0.0 for Flink 1.17, release candidate #2

2023-04-20 Thread Ahmed Hamdy
+1 (non-binding) - Release notes look good. - verified signatures and checksums are correct. - Verified no binaries in source archive. - Built from source - Approved Web PR (no comments if we are supporting 1.17+) Best Regards Ahmed On Thu, 20 Apr 2023 at 17:08, Danny Cranmer wrote: > +1

Re: [VOTE] Release flink-connector-mongodb v1.0.1, release candidate #1

2023-04-20 Thread Ahmed Hamdy
+1 (non-bindnig) - Checked JIRA release notes - verified hashes - verified signatures - built from source code succeeded - checked Github release tag - verified pom files point to version - reviewed and Approved web PR Best Ahmed Hamdy On Thu, 20 Apr 2023 at 02:43, Leonard Xu wrote: > +1

Re: [VOTE] Release flink-connector-kafka 3.0.0 for Flink 1.17, release candidate #2

2023-04-20 Thread Danny Cranmer
+1 (binding) - +1 on skipping 1.16 - Release notes look ok - Verified signature/hashes of source archive - Verified there are no binaries in the source archive - Built from source - Contents of Maven repo look good - Verified NOTICE files - Tag exists in Github - Reviewed web PR (looks good apart

Re: [VOTE] Release flink-shaded 17.0, release candidate #1

2023-04-20 Thread Matthias Pohl
Thanks Martijn for driving the flink-shaded release. +1 (non-binding) * Downloaded artifact * Verified SHA512 checksums * GPG signatures Compared * checkout with provided sources * Verified pom file versions * Went over NOTICE file/pom files changes once more without finding anything suspicious

[jira] [Created] (FLINK-31871) Interpret Flink MemoryUnits according to the actual user input

2023-04-20 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-31871: - Summary: Interpret Flink MemoryUnits according to the actual user input Key: FLINK-31871 URL: https://issues.apache.org/jira/browse/FLINK-31871 Project:

Re: [VOTE] Release flink-connector-elasticsearch, release candidate #1

2023-04-20 Thread Danny Cranmer
+1 (binding) - Release notes look ok - Verified signature/hashes of source archive - Verified there are no binaries in the source archive - Contents of Maven repo look good - Verified NOTICE files - Tag exists in Github - Reviewed web PR Not a blocker - Copyright year in NOTICE file needs to be

Re: DefaultInputSplitAssigner question

2023-04-20 Thread Péter Váry
Created a PR for the change: https://github.com/apache/flink/pull/22437 Could you please review Zhu? Thanks, Peter Péter Váry ezt írta (időpont: 2023. ápr. 20., Cs, 13:54): > Thanks Zhu for the quick response! > > In the Iceberg Flink Source (old version, there is a FLIP-27 version as > well)

[jira] [Created] (FLINK-31870) Cassandra input/output formats documentation is missing

2023-04-20 Thread Etienne Chauchot (Jira)
Etienne Chauchot created FLINK-31870: Summary: Cassandra input/output formats documentation is missing Key: FLINK-31870 URL: https://issues.apache.org/jira/browse/FLINK-31870 Project: Flink

[jira] [Created] (FLINK-31869) test_multi_sessionjob.sh gets stuck very frequently

2023-04-20 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-31869: -- Summary: test_multi_sessionjob.sh gets stuck very frequently Key: FLINK-31869 URL: https://issues.apache.org/jira/browse/FLINK-31869 Project: Flink Issue Type:

[VOTE] Release flink-shaded 17.0, release candidate #1

2023-04-20 Thread Martijn Visser
Hi everyone, Please review and vote on the release candidate #1 for the version 17.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1], *

Re: [VOTE] FLIP-304: Pluggable Failure Enrichers

2023-04-20 Thread Anton Kalashnikov
+1 (binding) Thanks for this FLIP Panos, LGTM. -- Best regards, Anton Kalashnikov On 20.04.23 13:44, Roman Khachatryan wrote: +1 (binding) The FLIP LGTM, thanks Panos! Regards, Roman On Thu, Apr 20, 2023 at 1:33 PM Hong Teoh wrote: +1 (non-binding) Thank you for driving this effort,

Re: DefaultInputSplitAssigner question

2023-04-20 Thread Péter Váry
Thanks Zhu for the quick response! In the Iceberg Flink Source (old version, there is a FLIP-27 version as well) the class is used [1], that is how I found it. Created a jira to update the doc [2]. Peter [1]

Re: [VOTE] FLIP-304: Pluggable Failure Enrichers

2023-04-20 Thread Roman Khachatryan
+1 (binding) The FLIP LGTM, thanks Panos! Regards, Roman On Thu, Apr 20, 2023 at 1:33 PM Hong Teoh wrote: > +1 (non-binding) > > Thank you for driving this effort, Panagiotis. > > Regards, > Hong > > > > On 20 Apr 2023, at 12:16, David Morávek wrote: > > > > Thanks for the update! > > > >

[jira] [Created] (FLINK-31868) Fix DefaultInputSplitAssigner javadoc for class

2023-04-20 Thread Peter Vary (Jira)
Peter Vary created FLINK-31868: -- Summary: Fix DefaultInputSplitAssigner javadoc for class Key: FLINK-31868 URL: https://issues.apache.org/jira/browse/FLINK-31868 Project: Flink Issue Type:

[jira] [Created] (FLINK-31867) Enforce a minimum number of observations within a metric window

2023-04-20 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-31867: -- Summary: Enforce a minimum number of observations within a metric window Key: FLINK-31867 URL: https://issues.apache.org/jira/browse/FLINK-31867 Project:

Re: [VOTE] FLIP-304: Pluggable Failure Enrichers

2023-04-20 Thread Hong Teoh
+1 (non-binding) Thank you for driving this effort, Panagiotis. Regards, Hong > On 20 Apr 2023, at 12:16, David Morávek wrote: > > Thanks for the update! > > +1 (binding) > > Best, > D. > > On Thu, Apr 20, 2023 at 9:50 AM Piotr Nowojski wrote: > >> Hi, >> >> I see that the FLIP has

[jira] [Created] (FLINK-31866) Autoscaler metric trimming reduces the numbet of metric observations

2023-04-20 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-31866: -- Summary: Autoscaler metric trimming reduces the numbet of metric observations Key: FLINK-31866 URL: https://issues.apache.org/jira/browse/FLINK-31866

Re: [VOTE] FLIP-304: Pluggable Failure Enrichers

2023-04-20 Thread David Morávek
Thanks for the update! +1 (binding) Best, D. On Thu, Apr 20, 2023 at 9:50 AM Piotr Nowojski wrote: > Hi, > > I see that the FLIP has been updated, thanks Panos! > > +1 (binding) > > Best, > Piotrek > > śr., 19 kwi 2023 o 13:49 Piotr Nowojski > napisał(a): > > > +1 to what David wrote. I

[jira] [Created] (FLINK-31865) Flink hive parser support order by non select column

2023-04-20 Thread yunfan (Jira)
yunfan created FLINK-31865: -- Summary: Flink hive parser support order by non select column Key: FLINK-31865 URL: https://issues.apache.org/jira/browse/FLINK-31865 Project: Flink Issue Type:

[jira] [Created] (FLINK-31864) Generate unaligned checkpoint type based on persisted data

2023-04-20 Thread Rui Fan (Jira)
Rui Fan created FLINK-31864: --- Summary: Generate unaligned checkpoint type based on persisted data Key: FLINK-31864 URL: https://issues.apache.org/jira/browse/FLINK-31864 Project: Flink Issue Type:

[jira] [Created] (FLINK-31863) Add 'Hostname' enum val to k8s NodeAddress type.

2023-04-20 Thread Vince.Feng (Jira)
Vince.Feng created FLINK-31863: -- Summary: Add 'Hostname' enum val to k8s NodeAddress type. Key: FLINK-31863 URL: https://issues.apache.org/jira/browse/FLINK-31863 Project: Flink Issue Type:

Re: [VOTE] FLIP-304: Pluggable Failure Enrichers

2023-04-20 Thread Piotr Nowojski
Hi, I see that the FLIP has been updated, thanks Panos! +1 (binding) Best, Piotrek śr., 19 kwi 2023 o 13:49 Piotr Nowojski napisał(a): > +1 to what David wrote. I think we need to update the FLIP and extend the > voting? > > Piotrek > > śr., 19 kwi 2023 o 09:06 David Morávek napisał(a): >

[jira] [Created] (FLINK-31862) KafkaSinkITCase.testStartFromSavepoint is unstable

2023-04-20 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-31862: --- Summary: KafkaSinkITCase.testStartFromSavepoint is unstable Key: FLINK-31862 URL: https://issues.apache.org/jira/browse/FLINK-31862 Project: Flink