Re: [VOTE] FLIP-275: Support Remote SQL Client Based on SQL Gateway

2022-12-20 Thread godfrey he
+1 (binding) Best, Godfrey Hang Ruan 于2022年12月21日周三 15:21写道: > > +1 (non-binding) > > Best, > Hang > > Paul Lam 于2022年12月20日周二 17:36写道: > > > +1 (non-binding) > > > > Best, > > Paul Lam > > > > > 2022年12月20日 11:35,Shengkai Fang 写道: > > > > > > +1(binding) > > > > > > Best, > > > Shengkai > > >

[jira] [Created] (FLINK-30470) Change groupId for flink-connector-parent

2022-12-20 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30470: -- Summary: Change groupId for flink-connector-parent Key: FLINK-30470 URL: https://issues.apache.org/jira/browse/FLINK-30470 Project: Flink Issue Type: Tec

[jira] [Created] (FLINK-30469) FLIP-266: Simplify network memory configurations for TaskManager

2022-12-20 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-30469: - Summary: FLIP-266: Simplify network memory configurations for TaskManager Key: FLINK-30469 URL: https://issues.apache.org/jira/browse/FLINK-30469 Project: Flink I

Re: [DISCUSS] Release Flink 1.16.1

2022-12-20 Thread godfrey he
Hi Martijn, Thank you for bringing this up. About Lincoln mentioned 3 commits, +1 to pick them into 1.16.1. AFAIK, several users have encountered this kind of data correctness problem so far, they are waiting a fix release as soon as possible. Best, Godfrey ConradJam 于2022年12月20日周二 15:08写道: >

[RESULT][VOTE] FLIP-277: Glue native catalog support in Flink

2022-12-20 Thread Samrat Deb
Hi Flink Devs, FLIP-277: Glue native catalog support in Flink[1] has been accepted. There are 4 binding votes and 1 non-binding votes Binding votes in favour: 1. Jark Wu 2. Danny Cranmer 3. Dong Lin 4. Konstantin Knauf Non-binding: 1. Yuxia There are no disapproving votes. Bests, Samrat [1] h

Re: [VOTE] FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

2022-12-20 Thread Dong Lin
The vote will last for at least 72 hours (Dec 26 at 8 am UTC, excluding weekend days). It needs consensus approval, requiring 3 binding +1 votes and no binding vetoes. On Wed, Dec 21, 2022 at 3:13 PM Dong Lin wrote: > Hi all, > > We would like to start the vote for FLIP-208: Add RecordEvaluator

Re: [VOTE] FLIP-275: Support Remote SQL Client Based on SQL Gateway

2022-12-20 Thread Hang Ruan
+1 (non-binding) Best, Hang Paul Lam 于2022年12月20日周二 17:36写道: > +1 (non-binding) > > Best, > Paul Lam > > > 2022年12月20日 11:35,Shengkai Fang 写道: > > > > +1(binding) > > > > Best, > > Shengkai > > > > yu zelin 于2022年12月14日周三 20:41写道: > > > >> Hi, all, > >> > >> Thanks for all your feedbacks so f

Re: [VOTE] FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

2022-12-20 Thread Hang Ruan
+1 (non-binding) Best, Hang Dong Lin 于2022年12月21日周三 15:13写道: > Hi all, > > We would like to start the vote for FLIP-208: Add RecordEvaluator to > dynamically stop source based on de-serialized records [1]. This FLIP was > discussed in this thread [2]. > > This feature is needed by users who cur

[VOTE] FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

2022-12-20 Thread Dong Lin
Hi all, We would like to start the vote for FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records [1]. This FLIP was discussed in this thread [2]. This feature is needed by users who currently depend on KafkaDeserializationSchema::isEndOfStream() to migrate their

[jira] [Created] (FLINK-30468) The SortOrder of BusyRatio should be descend by default

2022-12-20 Thread Rui Fan (Jira)
Rui Fan created FLINK-30468: --- Summary: The SortOrder of BusyRatio should be descend by default Key: FLINK-30468 URL: https://issues.apache.org/jira/browse/FLINK-30468 Project: Flink Issue Type: Bug

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

2022-12-20 Thread Thomas Weise
+1 (binding) * Checked hash and signature * Build from source and run tests * Checked licenses On Mon, Dec 19, 2022 at 1:50 PM Maximilian Michels wrote: > +1 (binding) > > Release looks good. > > 1. Downloaded the source archive release staged at > > https://dist.apache.org/repos/dist/dev/fli

[jira] [Created] (FLINK-30467) Improve the accuracy of estimating the row count of LocalHashAgg to make more two-phase HashAgg operators effective

2022-12-20 Thread Yunhong Zheng (Jira)
Yunhong Zheng created FLINK-30467: - Summary: Improve the accuracy of estimating the row count of LocalHashAgg to make more two-phase HashAgg operators effective Key: FLINK-30467 URL: https://issues.apache.org/jir

[jira] [Created] (FLINK-30466) Detect ineffective scaling operations

2022-12-20 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30466: -- Summary: Detect ineffective scaling operations Key: FLINK-30466 URL: https://issues.apache.org/jira/browse/FLINK-30466 Project: Flink Issue Type: New Feature

Re: [VOTE] Release flink-connector-jdbc, release candidate #2

2022-12-20 Thread Danny Cranmer
Hello, +1 (binding) - Release notes look good - Verified signatures and hashes - Verified there are no binaries in the source archive - NOTICE/Licenses look good - Built source - Tag exists in Github - Contents of Maven repo look good - Reviewed web PR Thanks, On Tue, Dec 20, 2022 at 12:04 PM M

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

2022-12-20 Thread Dawid Wysakowicz
+1 (binding) * Validated hashes * Verified signature * Verified that no binaries exist in the source archive * Built the source with Maven * Verified licenses * Verified web PR Best, Dawid On 20/12/2022 13:04, Martijn Visser wrote: +1 (binding) - Validated hashes - Verified signature -

[jira] [Created] (FLINK-30465) Remove flink-connector-jdbc

2022-12-20 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30465: -- Summary: Remove flink-connector-jdbc Key: FLINK-30465 URL: https://issues.apache.org/jira/browse/FLINK-30465 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-30464) Exclude metrics during stabilization period from the scaling decision

2022-12-20 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-30464: -- Summary: Exclude metrics during stabilization period from the scaling decision Key: FLINK-30464 URL: https://issues.apache.org/jira/browse/FLINK-30464 Pro

Re: [VOTE] Release flink-connector-jdbc, release candidate #2

2022-12-20 Thread Martijn Visser
+1 (binding) - Validated hashes - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven - Verified licenses - Verified web PR On Mon, Dec 19, 2022 at 3:53 PM Dawid Wysakowicz wrote: > +1 (binding) > >- verified signatures and checksums >

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

2022-12-20 Thread Martijn Visser
+1 (binding) - Validated hashes - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven - Verified licenses - Verified web PR On Mon, Dec 19, 2022 at 7:31 PM Danny Cranmer wrote: > Hello Martijn, > > +1 (binding) > > - Verified signatures and h

Re: [VOTE] Release flink-connector-pulsar, release candidate #5

2022-12-20 Thread Martijn Visser
+1 (binding) - Validated hashes - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven - Verified licenses - Verified web PR On Tue, Dec 20, 2022 at 10:11 AM Ahmed Hamdy wrote: > Hello, > Thank you > +1 (non-binding) > > Verified signatures an

[jira] [Created] (FLINK-30463) Stabilization period starts before job goes into RUNNING

2022-12-20 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-30463: -- Summary: Stabilization period starts before job goes into RUNNING Key: FLINK-30463 URL: https://issues.apache.org/jira/browse/FLINK-30463 Project: Flink

[jira] [Created] (FLINK-30462) DefaultMultipleComponentLeaderElectionService saves wrong leader session ID

2022-12-20 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30462: - Summary: DefaultMultipleComponentLeaderElectionService saves wrong leader session ID Key: FLINK-30462 URL: https://issues.apache.org/jira/browse/FLINK-30462 Project

[jira] [Created] (FLINK-30461) Some rocksdb sst files will remain forever

2022-12-20 Thread Rui Fan (Jira)
Rui Fan created FLINK-30461: --- Summary: Some rocksdb sst files will remain forever Key: FLINK-30461 URL: https://issues.apache.org/jira/browse/FLINK-30461 Project: Flink Issue Type: Bug Co

[jira] [Created] (FLINK-30460) Support writing HBase's CEIL TTL metadata

2022-12-20 Thread tanjialiang (Jira)
tanjialiang created FLINK-30460: --- Summary: Support writing HBase's CEIL TTL metadata Key: FLINK-30460 URL: https://issues.apache.org/jira/browse/FLINK-30460 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-30459) SQL Client supports "SET 'property'"

2022-12-20 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-30459: - Summary: SQL Client supports "SET 'property'" Key: FLINK-30459 URL: https://issues.apache.org/jira/browse/FLINK-30459 Project: Flink Issue Type: Improvemen

Re: [VOTE] FLIP-275: Support Remote SQL Client Based on SQL Gateway

2022-12-20 Thread Paul Lam
+1 (non-binding) Best, Paul Lam > 2022年12月20日 11:35,Shengkai Fang 写道: > > +1(binding) > > Best, > Shengkai > > yu zelin 于2022年12月14日周三 20:41写道: > >> Hi, all, >> >> Thanks for all your feedbacks so far. Through the discussion on this >> thread[1], I think we have came to a consensus, so I’d

Re: [VOTE] Release flink-connector-pulsar, release candidate #5

2022-12-20 Thread Ahmed Hamdy
Hello, Thank you +1 (non-binding) Verified signatures and checksums Verified source artifact does not contain binaries Verified tag Verified NOTICE file Built from source Best regards Ahmed Hamdy On Mon, 19 Dec 2022 at 18:48, Danny Cranmer wrote: > Hello all, > > +1 (binding) > > - Verified si

[jira] [Created] (FLINK-30458) Refactor Table Store Documentation

2022-12-20 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-30458: --- Summary: Refactor Table Store Documentation Key: FLINK-30458 URL: https://issues.apache.org/jira/browse/FLINK-30458 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Add Flink Web3 Connector

2022-12-20 Thread Martijn Visser
Hi Junyao, I don't see value in this for the Apache Flink community. You're stating this as a 'Web3 connector' but are only referring to one specific project. If that project needs a Flink connector, I think it should be built and maintained by that project, not by the Flink community. Best regar