Re: [DISCUSS] FLIP-274 : Introduce metric group for OperatorCoordinator

2023-01-11 Thread Martijn Visser
Hi Hang, I'm a bit surprised that this has gone to a vote, given that Chesnay deliberately mentioned that he would vote against it as-is. I would expect that before going to a vote, he has had the opportunity to participate in this discussion. Best regards, Martijn On Tue, Jan 3, 2023 at 12:53

Re: [VOTE] FLIP-274: Introduce metric group for OperatorCoordinator

2023-01-11 Thread Martijn Visser
-1 (binding) currently: I don't think this should have gone to a vote yet given that Chesnay deliberately mentioned that he would vote against it as-is. The discussion should have been settled first. On Tue, Jan 10, 2023 at 10:51 AM Zhu Zhu wrote: > +1 (binding) > > Thanks, > Zhu > > Jark Wu 于2

[jira] [Created] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

2023-01-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-30629: Summary: ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable Key: FLINK-30629 URL: https://issues.apache.org/jira/browse/FLINK-30629 Project: Flink

[jira] [Created] (FLINK-30630) Python: BatchModeDataStreamTests.test_keyed_map failed

2023-01-11 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30630: - Summary: Python: BatchModeDataStreamTests.test_keyed_map failed Key: FLINK-30630 URL: https://issues.apache.org/jira/browse/FLINK-30630 Project: Flink Issu

[jira] [Created] (FLINK-30631) Limit the max number of subpartitons consumed by each downstream task

2023-01-11 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-30631: -- Summary: Limit the max number of subpartitons consumed by each downstream task Key: FLINK-30631 URL: https://issues.apache.org/jira/browse/FLINK-30631 Project: Flink

[jira] [Created] (FLINK-30632) Introduce DataType for table store

2023-01-11 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-30632: Summary: Introduce DataType for table store Key: FLINK-30632 URL: https://issues.apache.org/jira/browse/FLINK-30632 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-30633) Update AWS SDKv2 to v2.19.14

2023-01-11 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-30633: - Summary: Update AWS SDKv2 to v2.19.14 Key: FLINK-30633 URL: https://issues.apache.org/jira/browse/FLINK-30633 Project: Flink Issue Type: Improvement

Re: [ANNOUNCE] New Apache Flink Committer - Lincoln Lee

2023-01-11 Thread Shuo Cheng
Congratulations, Lincoln! On Tue, Jan 10, 2023 at 11:52 AM Jark Wu wrote: > Hi everyone, > > On behalf of the PMC, I'm very happy to announce Lincoln Lee as a new Flink > committer. > > Lincoln Lee has been a long-term Flink contributor since 2017. He mainly > works on Flink > SQL parts and driv

[jira] [Created] (FLINK-30634) HiveTableSourceITCase.setupSourceDatabaseAndData fails with InvalidObjectException

2023-01-11 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30634: - Summary: HiveTableSourceITCase.setupSourceDatabaseAndData fails with InvalidObjectException Key: FLINK-30634 URL: https://issues.apache.org/jira/browse/FLINK-30634

[jira] [Created] (FLINK-30635) Fail to recover for row-format when writing to OSS using FileSystemTable connector

2023-01-11 Thread luoyuxia (Jira)
luoyuxia created FLINK-30635: Summary: Fail to recover for row-format when writing to OSS using FileSystemTable connector Key: FLINK-30635 URL: https://issues.apache.org/jira/browse/FLINK-30635 Project: F

Re: [VOTE] FLIP-274: Introduce metric group for OperatorCoordinator

2023-01-11 Thread Jark Wu
Hi Martijn, I think we should have a reasonable time window to wait for the discussion response. Many proposals will halt if we have to wait for every reply indefinitely. Chesnay raised some concerns in the thread one month ago and no objections or feedback after that. Hang replied to all the ques

Re: [ANNOUNCE] New Apache Flink Committer - Lincoln Lee

2023-01-11 Thread Matthias Pohl
Congratulations, Lincoln! On Wed, Jan 11, 2023 at 10:17 AM Shuo Cheng wrote: > Congratulations, Lincoln! > > On Tue, Jan 10, 2023 at 11:52 AM Jark Wu wrote: > > > Hi everyone, > > > > On behalf of the PMC, I'm very happy to announce Lincoln Lee as a new > Flink > > committer. > > > > Lincoln Le

[jira] [Created] (FLINK-30636) Typo fix: "to to" -> "to"

2023-01-11 Thread Gunnar Morling (Jira)
Gunnar Morling created FLINK-30636: -- Summary: Typo fix: "to to" -> "to" Key: FLINK-30636 URL: https://issues.apache.org/jira/browse/FLINK-30636 Project: Flink Issue Type: Technical Debt

Re: [ANNOUNCE] New Apache Flink Committer - Lincoln Lee

2023-01-11 Thread Xintong Song
Congratulations, Lincoln! Well deserved. Best, Xintong On Wed, Jan 11, 2023 at 5:48 PM Matthias Pohl wrote: > Congratulations, Lincoln! > > On Wed, Jan 11, 2023 at 10:17 AM Shuo Cheng wrote: > > > Congratulations, Lincoln! > > > > On Tue, Jan 10, 2023 at 11:52 AM Jark Wu wrote: > > > > > H

Re: [ANNOUNCE] New Apache Flink Committer - Lincoln Lee

2023-01-11 Thread Jun Qin
Congrats, Lincoln! Well deserved! > On Jan 11, 2023, at 11:23 AM, Xintong Song wrote: > > Congratulations, Lincoln! Well deserved. > > Best, > > Xintong > > > > On Wed, Jan 11, 2023 at 5:48 PM Matthias Pohl > wrote: > >> Congratulations, Lincoln! >> >> On Wed, Jan 11, 2023 at 10:17 AM Sh

Re: [VOTE] FLIP-274: Introduce metric group for OperatorCoordinator

2023-01-11 Thread Dong Lin
Hi Martijn, A collaborative and active community is very important for any open-source project. Flink can succeed today because we have many experienced and passionate developers who collaborate together to develop Flink. It is important that developers can give constructive feedback and help each

Re: [ANNOUNCE] New Apache Flink Committer - Lincoln Lee

2023-01-11 Thread Dong Lin
Congratulations, Lincoln! Cheers, Dong On Tue, Jan 10, 2023 at 11:52 AM Jark Wu wrote: > Hi everyone, > > On behalf of the PMC, I'm very happy to announce Lincoln Lee as a new Flink > committer. > > Lincoln Lee has been a long-term Flink contributor since 2017. He mainly > works on Flink > SQL

[jira] [Created] (FLINK-30637) In linux-aarch64 environment, using “is” judgment to match the window type of overwindow have returned incorrect matching results

2023-01-11 Thread Xin Chen (Jira)
Xin Chen created FLINK-30637: Summary: In linux-aarch64 environment, using “is” judgment to match the window type of overwindow have returned incorrect matching results Key: FLINK-30637 URL: https://issues.apache.org/

Re: [VOTE] FLIP-274: Introduce metric group for OperatorCoordinator

2023-01-11 Thread Martijn Visser
Hi Jark and Dong, I fully understand your concerns in this case. I also think that this situation is an exception. This discussion started just before the holiday season in Europe started. The request to Chesnay if he had more comments was sent just a couple of days before Christmas. >From my per

Re: [ANNOUNCE] New Apache Flink Committer - Lincoln Lee

2023-01-11 Thread Martijn Visser
Congratulations Lincoln, happy to have you on board! Best regards, Martijn On Wed, Jan 11, 2023 at 1:49 PM Dong Lin wrote: > Congratulations, Lincoln! > > Cheers, > Dong > > On Tue, Jan 10, 2023 at 11:52 AM Jark Wu wrote: > > > Hi everyone, > > > > On behalf of the PMC, I'm very happy to anno

Re: [DISCUSS] FLIP-281 Sink Supports Speculative Execution For Batch Job

2023-01-11 Thread Martijn Visser
Hi Biao, Apologies for the late jumping in. My only question is about SinkFunction, does this imply that we want to add support for this to the SinkFunction? If so, I would not be in favour of that since we would like to deprecate (I actually thought that was already the case) the SinkFunction in

[jira] [Created] (FLINK-30638) Operator doesn't forward allowNonRestoredState flag

2023-01-11 Thread Alexis Sarda-Espinosa (Jira)
Alexis Sarda-Espinosa created FLINK-30638: - Summary: Operator doesn't forward allowNonRestoredState flag Key: FLINK-30638 URL: https://issues.apache.org/jira/browse/FLINK-30638 Project: Flink

Re: [VOTE] FLIP-274: Introduce metric group for OperatorCoordinator

2023-01-11 Thread Jark Wu
Hi Martijn, Thanks for helping us to find Chesnay. Could you clarify how "soon" will Chesnay participate? A day or a week? I agree with your improvement proposal and Hang exactly follows your points. The last-call-for-discussion for Chensay has been sent for more than 72 hours, even after the Chr

Re: [VOTE] FLIP-274: Introduce metric group for OperatorCoordinator

2023-01-11 Thread Martijn Visser
Hi Jark, I disagree with your statement that someone doesn't care about the FLIP, especially since that person participated in the initial FLIP discussion and mentioned explicitly "Since I'm on holidays soon, just so no one tries to pull a fast one on me, if this were to go to a vote as-is I'd be

[jira] [Created] (FLINK-30639) Publish SBOM for externalized connectors

2023-01-11 Thread Jira
Márton Balassi created FLINK-30639: -- Summary: Publish SBOM for externalized connectors Key: FLINK-30639 URL: https://issues.apache.org/jira/browse/FLINK-30639 Project: Flink Issue Type: Sub-

Re: "Introduction to Apache Flink" presentation

2023-01-11 Thread Ryan Skraba
Hello Joe -- sorry for the late reply, a colleague just showed me this. I don't know if you're aware, but there's an incubating project called Apache Training (Incubating) [1] that collects introductory and training materials for various Apache projects. All ASF committers have write permissions

Re: [VOTE] FLIP-274: Introduce metric group for OperatorCoordinator

2023-01-11 Thread Chesnay Schepler
You know, back when I wrote that line I actually felt a bit guilty about it and nearly dropped it, since it implicitly accused _someone_ of actually being capable/willing to push something through despite voiced concerns while no ones looking. Turns out things are a lot worse that I thought. Y

Re: [ANNOUNCE] New Apache Flink Committer - Lincoln Lee

2023-01-11 Thread Yu Li
Congratulations, Lincoln! Best Regards, Yu On Wed, 11 Jan 2023 at 21:17, Martijn Visser wrote: > Congratulations Lincoln, happy to have you on board! > > Best regards, Martijn > > > On Wed, Jan 11, 2023 at 1:49 PM Dong Lin wrote: > > > Congratulations, Lincoln! > > > > Cheers, > > Dong > > >

Re: [ANNOUNCE] New Apache Flink Committer - Lincoln Lee

2023-01-11 Thread liu ron
Congratulations, Lincoln! Best Yu Li 于2023年1月12日周四 09:22写道: > Congratulations, Lincoln! > > Best Regards, > Yu > > > On Wed, 11 Jan 2023 at 21:17, Martijn Visser > wrote: > > > Congratulations Lincoln, happy to have you on board! > > > > Best regards, Martijn > > > > > > On Wed, Jan 11, 2023 a

Re: [ANNOUNCE] New Apache Flink Committer - Lincoln Lee

2023-01-11 Thread Shengkai Fang
Congratulations, Lincoln! Best, Shengkai liu ron 于2023年1月12日周四 09:48写道: > Congratulations, Lincoln! > > Best > > Yu Li 于2023年1月12日周四 09:22写道: > > > Congratulations, Lincoln! > > > > Best Regards, > > Yu > > > > > > On Wed, 11 Jan 2023 at 21:17, Martijn Visser > > wrote: > > > > > Congratulati

Re: [VOTE] FLIP-274: Introduce metric group for OperatorCoordinator

2023-01-11 Thread Hang Ruan
Hi, all, Thanks for all discussions about this FLIP first. We all are trying to make Flink better. But not getting a reply quickly really discourages contributors. OperatorCoordinatorMetricGroup and SplitEnumeratorMetricGroup are important for many developers. And many metrics can not be reported

Re: [ANNOUNCE] New Apache Flink Committer - Lincoln Lee

2023-01-11 Thread Lincoln Lee
Thank you all! I'm honored to join the committers and look forward to continue working with the community. Best, Lincoln Lee Shengkai Fang 于2023年1月12日周四 09:55写道: > Congratulations, Lincoln! > > Best, > Shengkai > > liu ron 于2023年1月12日周四 09:48写道: > > > Congratulations, Lincoln! > > > > Best >

Re: [VOTE] FLIP-274: Introduce metric group for OperatorCoordinator

2023-01-11 Thread Xintong Song
Hi all, AFAICS, there’s no consensus so far on how we should proceed discussions while some of the participants are unresponsive, in either the Bylaws[1] or any of the ML threads that I’m aware of. Without such consensus, it is understandable that contributors take actions based on their different

[jira] [Created] (FLINK-30640) Unstable test in CliClientITCase

2023-01-11 Thread yuzelin (Jira)
yuzelin created FLINK-30640: --- Summary: Unstable test in CliClientITCase Key: FLINK-30640 URL: https://issues.apache.org/jira/browse/FLINK-30640 Project: Flink Issue Type: Bug Components:

Re: [VOTE] Apache Flink Table Store 0.3.0, release candidate #1

2023-01-11 Thread Yu Li
Hi Jingsong, It seems the given staging directory [1] is not exposed, could you double check and republish if necessary? Thanks. Best Regards, Yu [1] https://repository.apache.org/content/repositories/orgapacheflink-1576/ On Tue, 10 Jan 2023 at 16:53, Jingsong Li wrote: > Hi everyone, > > Pl

[jira] [Created] (FLINK-30641) docs_404_check fail

2023-01-11 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-30641: -- Summary: docs_404_check fail Key: FLINK-30641 URL: https://issues.apache.org/jira/browse/FLINK-30641 Project: Flink Issue Type: Bug Reporter: Lijie W

Re: [VOTE] Apache Flink Table Store 0.3.0, release candidate #1

2023-01-11 Thread Jingsong Li
Thanks Yu for your validation. I created a new staging directory [1] [1] https://repository.apache.org/content/repositories/orgapacheflink-1577/ Best, Jingsong On Thu, Jan 12, 2023 at 3:07 PM Yu Li wrote: > > Hi Jingsong, > > It seems the given staging directory [1] is not exposed, could you d

Re: [DISCUSS] FLIP-281 Sink Supports Speculative Execution For Batch Job

2023-01-11 Thread Biao Liu
Hi Martijn, Thanks for your feedback! Yes, we propose to support speculative execution for SinkFunction. 1. From the perspective of compatibility, SinkFunction is the most original Sink implementation.There are lots of implementations based on SinkFunction, not only in Flink official codebase but

Re: [DISCUSS] FLIP-281 Sink Supports Speculative Execution For Batch Job

2023-01-11 Thread Martijn Visser
Hi Biao, While I rather wouldn't add new features to (to-be) deprecated features, I would be +0 for this. Best regards, Martijn Op do 12 jan. 2023 om 08:42 schreef Biao Liu : > Hi Martijn, > > Thanks for your feedback! > > Yes, we propose to support speculative execution for SinkFunction. > 1.

Re: [VOTE] FLIP-281: Sink Supports Speculative Execution For Batch Job

2023-01-11 Thread Martijn Visser
+0 (binding) Op di 10 jan. 2023 om 13:11 schreef yuxia : > +1 (non-binding). > > Best regards, > Yuxia > > - 原始邮件 - > 发件人: "Zhu Zhu" > 收件人: "dev" > 发送时间: 星期二, 2023年 1 月 10日 下午 5:50:39 > 主题: Re: [VOTE] FLIP-281: Sink Supports Speculative Execution For Batch Job > > +1 (binding) > > Thank