[jira] [Created] (FLINK-34504) Avoid the parallelism adjutment when the upstream shuffle type doesn't has keyBy

2024-02-23 Thread Rui Fan (Jira)
Rui Fan created FLINK-34504: --- Summary: Avoid the parallelism adjutment when the upstream shuffle type doesn't has keyBy Key: FLINK-34504 URL: https://issues.apache.org/jira/browse/FLINK-34504 Project: Flink

[jira] [Created] (FLINK-34505) Migrate WindowGroupReorderRule

2024-02-23 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-34505: - Summary: Migrate WindowGroupReorderRule Key: FLINK-34505 URL: https://issues.apache.org/jira/browse/FLINK-34505 Project: Flink Issue Type: Sub-task Compo

[jira] [Created] (FLINK-34506) Do not copy "file://" schemed artifact in standalone application modes

2024-02-23 Thread Ferenc Csaky (Jira)
Ferenc Csaky created FLINK-34506: Summary: Do not copy "file://" schemed artifact in standalone application modes Key: FLINK-34506 URL: https://issues.apache.org/jira/browse/FLINK-34506 Project: Flink

[jira] [Created] (FLINK-34507) JSON functions have wrong operand checker

2024-02-23 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-34507: Summary: JSON functions have wrong operand checker Key: FLINK-34507 URL: https://issues.apache.org/jira/browse/FLINK-34507 Project: Flink Issue Type:

Re: [DISCUSS]FLIP-420: Add API annotations for RocksDB StateBackend user-facing classes

2024-02-23 Thread Yun Tang
Hi Jinzhong, Thanks for driving this topic, and +1 for fixing the lack of annotation. @Yanfei the `ConfigurableRocksDBOptionsFactory` interface is introduced for user extension, you can refer to the doc[1], which shows an example of how to use this interface. [1] https://nightlies.apache.org

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-23 Thread Yun Tang
Congratulations, Jiabao! Best Yun Tang From: Weihua Hu Sent: Thursday, February 22, 2024 17:29 To: dev@flink.apache.org Subject: Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun Congratulations, Jiabao! Best, Weihua On Thu, Feb 22, 2024 at 10:34 AM Jing

[jira] [Created] (FLINK-34508) Migrate S3-related ITCases and e2e tests to Minio

2024-02-23 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34508: - Summary: Migrate S3-related ITCases and e2e tests to Minio Key: FLINK-34508 URL: https://issues.apache.org/jira/browse/FLINK-34508 Project: Flink Issue Ty

[jira] [Created] (FLINK-34509) Docs: Fix Debezium JSON/AVRO opts in examples

2024-02-23 Thread Lorenzo Affetti (Jira)
Lorenzo Affetti created FLINK-34509: --- Summary: Docs: Fix Debezium JSON/AVRO opts in examples Key: FLINK-34509 URL: https://issues.apache.org/jira/browse/FLINK-34509 Project: Flink Issue Ty

Re: Temporal join on rolling aggregate

2024-02-23 Thread Feng Jin
+1 Support this feature. There are many limitations to using time window aggregation currently, and if we can declare watermark and time attribute on the view, it will make it easier for us to use time windows. Similarly, it would be very useful if the primary key could be declared in the view. Th

Re: Flink's treatment to "hadoop" and "yarn" configuration overrides seems unintuitive

2024-02-23 Thread Venkatakrishnan Sowrirajan
Gentle ping on the ^^ question to surface this back up again. Any thoughts? Regards Venkata krishnan On Fri, Feb 16, 2024 at 7:32 PM Venkatakrishnan Sowrirajan wrote: > Hi Flink devs, > > Flink supports overriding "hadoop" and "yarn" configuration. As part of > the override mechanism, users ha