[DISCUSS] FLINK-35571: ProfilingServiceTest improper test isolation

2024-06-13 Thread Grace Grimwood
Hi devs, I created a ticket FLINK-35571 - ProfilingServiceTest.testRollingDeletion intermittently fails due to improper test isolation[1] yesterday, and my colleagues and I were hoping to get some feedback on how best for us to fix it. We'd like to raise a PR to fix it, just want to be sure we und

[jira] [Created] (FLINK-35600) Data read duplication during the full-to-incremental conversion phase

2024-06-13 Thread Di Wu (Jira)
Di Wu created FLINK-35600: - Summary: Data read duplication during the full-to-incremental conversion phase Key: FLINK-35600 URL: https://issues.apache.org/jira/browse/FLINK-35600 Project: Flink Issu

[jira] [Created] (FLINK-35599) test

2024-06-13 Thread ZhengJunZhou (Jira)
ZhengJunZhou created FLINK-35599: Summary: test Key: FLINK-35599 URL: https://issues.apache.org/jira/browse/FLINK-35599 Project: Flink Issue Type: Bug Reporter: ZhengJunZhou

[jira] [Created] (FLINK-35598) Fix error comparison type ExtendedSqlRowTypeNameSpec#equalsDeep

2024-06-13 Thread Frank Wong (Jira)
Frank Wong created FLINK-35598: -- Summary: Fix error comparison type ExtendedSqlRowTypeNameSpec#equalsDeep Key: FLINK-35598 URL: https://issues.apache.org/jira/browse/FLINK-35598 Project: Flink

[jira] [Created] (FLINK-35597) Fix unstable LocatableSplitAssignerTest#testConcurrentSplitAssignmentForMultipleHosts

2024-06-13 Thread Yubin Li (Jira)
Yubin Li created FLINK-35597: Summary: Fix unstable LocatableSplitAssignerTest#testConcurrentSplitAssignmentForMultipleHosts Key: FLINK-35597 URL: https://issues.apache.org/jira/browse/FLINK-35597 Project

[jira] [Created] (FLINK-35596) Flink application fails with The implementation of the BlockElement is not serializable

2024-06-13 Thread Venkata krishnan Sowrirajan (Jira)
Venkata krishnan Sowrirajan created FLINK-35596: --- Summary: Flink application fails with The implementation of the BlockElement is not serializable Key: FLINK-35596 URL: https://issues.apache.org/jira

[jira] [Created] (FLINK-35595) MailboxProcessor#processMailsWhenDefaultActionUnavailable is allocation intensive

2024-06-13 Thread David Schlosnagle (Jira)
David Schlosnagle created FLINK-35595: - Summary: MailboxProcessor#processMailsWhenDefaultActionUnavailable is allocation intensive Key: FLINK-35595 URL: https://issues.apache.org/jira/browse/FLINK-35595

Re: [DISCUSS] FLIP-463: Schema Definition in CREATE TABLE AS Statement

2024-06-13 Thread Jeyhun Karimov
Thanks Sergio and Timo for your answers. Sounds good to me. Looking forward for this feature. Regards, Jeyhun On Thu, Jun 13, 2024 at 4:48 PM Sergio Pena wrote: > Sure Yuxia, I just added the support for RTAS statements too. > > - Sergio > > On Wed, Jun 12, 2024 at 8:22 PM yuxia wrote: > > > H

Re: [VOTE] FLIP-464: Merge "flink run" and "flink run-application"

2024-06-13 Thread Jeyhun Karimov
Thanks for driving this. +1 (non-binding) Regards, Jeyhun On Thu, Jun 13, 2024 at 5:23 PM Gabor Somogyi wrote: > +1 (binding) > > G > > > On Wed, Jun 12, 2024 at 5:23 PM Ferenc Csaky > wrote: > > > Hello devs, > > > > I would like to start a vote about FLIP-464 [1]. The FLIP is about to > > me

Re: [VOTE] FLIP-464: Merge "flink run" and "flink run-application"

2024-06-13 Thread Gabor Somogyi
+1 (binding) G On Wed, Jun 12, 2024 at 5:23 PM Ferenc Csaky wrote: > Hello devs, > > I would like to start a vote about FLIP-464 [1]. The FLIP is about to > merge back the > "flink run-application" functionality to "flink run", so the latter will > be capable to deploy jobs in > all deployment

Re: Re: Re: [DISCUSS] FLIP-462: Support Custom Data Distribution for Input Stream of Lookup Join

2024-06-13 Thread Lincoln Lee
Thanks Weijie & Wencong for your update including the conclusions of the offline discussion. There's one thing need to be confirmed in the FLIP: > The hint only provides a suggestion to the optimizer, it is not an enforcer. As a result, If the target dim table not implements SupportsLookupCustomSh

Re: [DISCUSS] FLIP-463: Schema Definition in CREATE TABLE AS Statement

2024-06-13 Thread Sergio Pena
Sure Yuxia, I just added the support for RTAS statements too. - Sergio On Wed, Jun 12, 2024 at 8:22 PM yuxia wrote: > Hi, Sergio. > Thanks for driving the FLIP. Given we also has REPLACE TABLE AS > Statement[1] and it's almost same with CREATE TABLE AS Statement, > would you mind also supportin

[jira] [Created] (FLINK-35594) Downscaling doesn't release TaskManagers.

2024-06-13 Thread Aviv Dozorets (Jira)
Aviv Dozorets created FLINK-35594: - Summary: Downscaling doesn't release TaskManagers. Key: FLINK-35594 URL: https://issues.apache.org/jira/browse/FLINK-35594 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35593) Apache Kubernetes Operator Docker image does not contain Apache LICENSE

2024-06-13 Thread Anupam Aggarwal (Jira)
Anupam Aggarwal created FLINK-35593: --- Summary: Apache Kubernetes Operator Docker image does not contain Apache LICENSE Key: FLINK-35593 URL: https://issues.apache.org/jira/browse/FLINK-35593 Project

[jira] [Created] (FLINK-35592) MysqlDebeziumTimeConverter miss timezone convert to timestamp

2024-06-13 Thread ZhengYu Chen (Jira)
ZhengYu Chen created FLINK-35592: Summary: MysqlDebeziumTimeConverter miss timezone convert to timestamp Key: FLINK-35592 URL: https://issues.apache.org/jira/browse/FLINK-35592 Project: Flink

[jira] [Created] (FLINK-35591) Azure Pipelines not running for master since c9def981

2024-06-13 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35591: -- Summary: Azure Pipelines not running for master since c9def981 Key: FLINK-35591 URL: https://issues.apache.org/jira/browse/FLINK-35591 Project: Flink Issue Type:

[jira] [Created] (FLINK-35589) Support MemorySize type in FlinkCDC ConfigOptions

2024-06-13 Thread LvYanquan (Jira)
LvYanquan created FLINK-35589: - Summary: Support MemorySize type in FlinkCDC ConfigOptions Key: FLINK-35589 URL: https://issues.apache.org/jira/browse/FLINK-35589 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-35590) Cleanup deprecated options usage in docs about state and checkpoint

2024-06-13 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-35590: --- Summary: Cleanup deprecated options usage in docs about state and checkpoint Key: FLINK-35590 URL: https://issues.apache.org/jira/browse/FLINK-35590 Project: Flink

Re: [DISCUSS] Connector Externalization Retrospective

2024-06-13 Thread Danny Cranmer
Thanks all for the feedback. @David > have a wizard / utility so the user inputs which Flink level they want and which connectors; the utility knows the compatibility matrix and downloads the appropriate bundles. My colleagues developed a Maven plugin [1] that performs static checks. Something l

[jira] [Created] (FLINK-35588) flink sql redis connector

2024-06-13 Thread cris niu (Jira)
cris niu created FLINK-35588: Summary: flink sql redis connector Key: FLINK-35588 URL: https://issues.apache.org/jira/browse/FLINK-35588 Project: Flink Issue Type: New Feature Reporte