[jira] [Created] (FLINK-35428) WindowJoinITCase#testInnerJoin failed on AZP as NPE

2024-05-23 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35428: -- Summary: WindowJoinITCase#testInnerJoin failed on AZP as NPE Key: FLINK-35428 URL: https://issues.apache.org/jira/browse/FLINK-35428 Project: Flink Issue Type: B

[jira] [Created] (FLINK-35429) We don't need introduce getFlinkConfigurationOptions for SqlGatewayRestEndpointFactory#Context

2024-05-23 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35429: -- Summary: We don't need introduce getFlinkConfigurationOptions for SqlGatewayRestEndpointFactory#Context Key: FLINK-35429 URL: https://issues.apache.org/jira/browse/FLINK-35429

[jira] [Created] (FLINK-35430) ZoneId is not passed to DebeziumJsonSerializationSchema

2024-05-23 Thread LvYanquan (Jira)
LvYanquan created FLINK-35430: - Summary: ZoneId is not passed to DebeziumJsonSerializationSchema Key: FLINK-35430 URL: https://issues.apache.org/jira/browse/FLINK-35430 Project: Flink Issue Type:

[jira] [Created] (FLINK-35431) Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0

2024-05-23 Thread Zhongqiang Gong (Jira)
Zhongqiang Gong created FLINK-35431: --- Summary: Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0 Key: FLINK-35431 URL: https://issues.apache.org/jira/browse/FLINK-35431 Project:

[jira] [Created] (FLINK-35432) Support catch modify-event for mysql-cdc

2024-05-23 Thread hk__lrzy (Jira)
hk__lrzy created FLINK-35432: Summary: Support catch modify-event for mysql-cdc Key: FLINK-35432 URL: https://issues.apache.org/jira/browse/FLINK-35432 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-35433) Provide a config parameter to set {{publishNotReadyAddresses}} option for the jobmanager's RPC Kubernetes service

2024-05-23 Thread Pavel (Jira)
Pavel created FLINK-35433: - Summary: Provide a config parameter to set {{publishNotReadyAddresses}} option for the jobmanager's RPC Kubernetes service Key: FLINK-35433 URL: https://issues.apache.org/jira/browse/FLINK-3543

[jira] [Created] (FLINK-35434) Support pass exception in StateExecutor to runtime

2024-05-23 Thread Feifan Wang (Jira)
Feifan Wang created FLINK-35434: --- Summary: Support pass exception in StateExecutor to runtime Key: FLINK-35434 URL: https://issues.apache.org/jira/browse/FLINK-35434 Project: Flink Issue Type:

[jira] [Created] (FLINK-35435) [FLIP-451] Introduce timeout configuration to AsyncSink

2024-05-23 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-35435: --- Summary: [FLIP-451] Introduce timeout configuration to AsyncSink Key: FLINK-35435 URL: https://issues.apache.org/jira/browse/FLINK-35435 Project: Flink Issue T

Re: [DISCUSS] FLIP-443: Interruptible watermark processing

2024-05-23 Thread Piotr Nowojski
Hi Zakelly, I've thought about it a bit more, and I think only `#execute()` methods make the most sense to be used when implementing operators (and interruptible mails), so I will just add `MailOptions` parameters only to them. If necessary, we can add more in the future. I have updated the FLIP.

[jira] [Created] (FLINK-35436) Job can't launch when setting the option schema.change.behavior to IGNORE

2024-05-23 Thread hk__lrzy (Jira)
hk__lrzy created FLINK-35436: Summary: Job can't launch when setting the option schema.change.behavior to IGNORE Key: FLINK-35436 URL: https://issues.apache.org/jira/browse/FLINK-35436 Project: Flink

Re: [DISCUSS] FLIP-443: Interruptible watermark processing

2024-05-23 Thread Zakelly Lan
Hi Piotrek, It looks good to me. Thanks for the update! Best, Zakelly On Thu, May 23, 2024 at 7:04 PM Piotr Nowojski wrote: > Hi Zakelly, > > I've thought about it a bit more, and I think only `#execute()` methods > make the most sense to be used when implementing operators (and > interruptib

[VOTE] FLIP-443: Interruptible watermark processing

2024-05-23 Thread Piotr Nowojski
Hi all, After reaching what looks like a consensus in the discussion thread [1], I would like to put FLIP-443 [2] to the vote. The vote will be open for at least 72 hours unless there is an objection or insufficient votes. [1] https://lists.apache.org/thread/flxm7rphvfgqdn2gq2z0bb7kl007olpz [2]

Re: [DISCUSSION] FLIP-457: Improve Table/SQL Configuration for Flink 2.0

2024-05-23 Thread Jane Chan
Hi Leonard, Thank you for the feedback and the improvement. If there are no further comments or concerns, I would like to initiate a vote on this. Best, Jane On Wed, May 22, 2024 at 9:24 PM Leonard Xu wrote: > Thanks Jane for the refine work, +1 from my side. > I adjusted the table format of

[jira] [Created] (FLINK-35437) BlockStatementGrouper uses lots of memory

2024-05-23 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-35437: Summary: BlockStatementGrouper uses lots of memory Key: FLINK-35437 URL: https://issues.apache.org/jira/browse/FLINK-35437 Project: Flink Issue Type:

[jira] [Created] (FLINK-35438) SourceCoordinatorTest.testErrorThrownFromSplitEnumerator fails on wrong error

2024-05-23 Thread Ryan Skraba (Jira)
Ryan Skraba created FLINK-35438: --- Summary: SourceCoordinatorTest.testErrorThrownFromSplitEnumerator fails on wrong error Key: FLINK-35438 URL: https://issues.apache.org/jira/browse/FLINK-35438 Project:

[jira] [Created] (FLINK-35439) Python Support for AvroSchemaConverter

2024-05-23 Thread Greg Wills (Jira)
Greg Wills created FLINK-35439: -- Summary: Python Support for AvroSchemaConverter Key: FLINK-35439 URL: https://issues.apache.org/jira/browse/FLINK-35439 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Proposing an LTS Release for the 1.x Line

2024-05-23 Thread Alexander Fedulov
Good point, Xintong, I incorporated this item into the FLIP. Best, Alex On Wed, 22 May 2024 at 10:37, Xintong Song wrote: > Thanks, Alex. > > I see one task that needs to be done once the FLIP is approved, which I'd > suggest to also mention in the: To explain the LTS policy to users on > websi

[jira] [Created] (FLINK-35440) unable to connect tableau to jdbc flink url using flink sql driver

2024-05-23 Thread Zach (Jira)
Zach created FLINK-35440: Summary: unable to connect tableau to jdbc flink url using flink sql driver Key: FLINK-35440 URL: https://issues.apache.org/jira/browse/FLINK-35440 Project: Flink Issue Typ

[VOTE] FLIP-457: Improve Table/SQL Configuration for Flink 2.0

2024-05-23 Thread Jane Chan
Hi all, I'd like to start a vote on FLIP-457[1] after reaching a consensus through the discussion thread[2]. The vote will be open for at least 72 hours unless there is an objection or insufficient votes. [1] https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=307136992 [2] https:/

Re: [VOTE] FLIP-443: Interruptible watermark processing

2024-05-23 Thread Zakelly Lan
+1 (binding) Best, Zakelly On Thu, May 23, 2024 at 8:21 PM Piotr Nowojski wrote: > Hi all, > > After reaching what looks like a consensus in the discussion thread [1], I > would like to put FLIP-443 [2] to the vote. > > The vote will be open for at least 72 hours unless there is an objection or

[jira] [Created] (FLINK-35441) Add CDC upgrade compatibility tests

2024-05-23 Thread yux (Jira)
yux created FLINK-35441: --- Summary: Add CDC upgrade compatibility tests Key: FLINK-35441 URL: https://issues.apache.org/jira/browse/FLINK-35441 Project: Flink Issue Type: Bug Components: Flink

[jira] [Created] (FLINK-35442) Kafka Pipeline Sink may distribute the same key to different partitions after modify parallelism

2024-05-23 Thread LvYanquan (Jira)
LvYanquan created FLINK-35442: - Summary: Kafka Pipeline Sink may distribute the same key to different partitions after modify parallelism Key: FLINK-35442 URL: https://issues.apache.org/jira/browse/FLINK-35442

Re: [VOTE] FLIP-443: Interruptible watermark processing

2024-05-23 Thread Yanfei Lei
Thanks for driving this! +1 (binding) Best, Yanfei Zakelly Lan 于2024年5月24日周五 10:13写道: > > +1 (binding) > > Best, > Zakelly > > On Thu, May 23, 2024 at 8:21 PM Piotr Nowojski wrote: > > > Hi all, > > > > After reaching what looks like a consensus in the discussion thread [1], I > > would like

Re: Discussion: Condition field in the CR status

2024-05-23 Thread Lajith Koova
Thanks David for the feedback. Yes you are right. We can provide meaningful information in reason rather than provide it as "Ready". Message will have more detailed information . Also updated document on how to handle multiple conditions in status. Thanks Lajith On Mon, May 13, 2024 at 4:00 PM D

Re: [VOTE] FLIP-457: Improve Table/SQL Configuration for Flink 2.0

2024-05-23 Thread Lincoln Lee
+1(binding) Best, Lincoln Lee Jane Chan 于2024年5月24日周五 09:52写道: > Hi all, > > I'd like to start a vote on FLIP-457[1] after reaching a consensus through > the discussion thread[2]. > > The vote will be open for at least 72 hours unless there is an objection or > insufficient votes. > > > [1] >

Re: [VOTE] FLIP-443: Interruptible watermark processing

2024-05-23 Thread Rui Fan
+1(binding) Best, Rui On Fri, May 24, 2024 at 12:01 PM Yanfei Lei wrote: > Thanks for driving this! > > +1 (binding) > > Best, > Yanfei > > Zakelly Lan 于2024年5月24日周五 10:13写道: > > > > > +1 (binding) > > > > Best, > > Zakelly > > > > On Thu, May 23, 2024 at 8:21 PM Piotr Nowojski > wrote: > > >

Re: [VOTE] FLIP-457: Improve Table/SQL Configuration for Flink 2.0

2024-05-23 Thread weijie guo
+1(binding) Best regards, Weijie Lincoln Lee 于2024年5月24日周五 12:20写道: > +1(binding) > > Best, > Lincoln Lee > > > Jane Chan 于2024年5月24日周五 09:52写道: > > > Hi all, > > > > I'd like to start a vote on FLIP-457[1] after reaching a consensus > through > > the discussion thread[2]. > > > > The vote w

Re: [VOTE] FLIP-443: Interruptible watermark processing

2024-05-23 Thread weijie guo
+1(binding) Thanks for driving this! Best regards, Weijie Rui Fan <1996fan...@gmail.com> 于2024年5月24日周五 13:03写道: > +1(binding) > > Best, > Rui > > On Fri, May 24, 2024 at 12:01 PM Yanfei Lei wrote: > > > Thanks for driving this! > > > > +1 (binding) > > > > Best, > > Yanfei > > > > Zakelly La

[jira] [Created] (FLINK-35443) ChangelogLocalRecoveryITCase failed fatally with 239 exit code

2024-05-23 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35443: -- Summary: ChangelogLocalRecoveryITCase failed fatally with 239 exit code Key: FLINK-35443 URL: https://issues.apache.org/jira/browse/FLINK-35443 Project: Flink I

Re: [VOTE] FLIP-457: Improve Table/SQL Configuration for Flink 2.0

2024-05-23 Thread Leonard Xu
+1 Best, Leonard > 2024年5月24日 下午1:27,weijie guo 写道: > > +1(binding) > > Best regards, > > Weijie > > > Lincoln Lee 于2024年5月24日周五 12:20写道: > >> +1(binding) >> >> Best, >> Lincoln Lee >> >> >> Jane Chan 于2024年5月24日周五 09:52写道: >> >>> Hi all, >>> >>> I'd like to start a vote on FLIP-457

Re: [VOTE] FLIP-457: Improve Table/SQL Configuration for Flink 2.0

2024-05-23 Thread Rui Fan
+1(binding) Best, Rui On Fri, May 24, 2024 at 1:45 PM Leonard Xu wrote: > +1 > > Best, > Leonard > > > 2024年5月24日 下午1:27,weijie guo 写道: > > > > +1(binding) > > > > Best regards, > > > > Weijie > > > > > > Lincoln Lee 于2024年5月24日周五 12:20写道: > > > >> +1(binding) > >> > >> Best, > >> Lincoln Lee