[jira] [Created] (FLINK-32306) Multiple batch scheduler performance regressions

Martijn Visser created FLINK-32306: -- Summary: Multiple batch scheduler performance regressions Key: FLINK-32306 URL: https://issues.apache.org/jira/browse/FLINK-32306 Project: Flink Issue Ty

[DISCUSS] FLIP-321: Introduce an API deprecation process

Hi folks, As one of the release 2.0 efforts, the release managers were discussing our API lifecycle policies. There have been FLIP-196[1] and FLIP-197[2] that are relevant to this topic. These two FLIPs defined the stability guarantee of the programming APIs with various different stability annota

Re: [DISCUSS] FLIP-246: Multi Cluster Kafka Source

Hi Mason, Thanks for the iterations on the FLIP, I think this is in a very good shape now. Small correction for the MultiClusterKafkaSourceEnumerator section: "This reader is responsible for discovering and assigning splits from 1+ cluster" Regarding the user facing name of the connector: I agre

Re: [DISCUSSION] Improved USER/SYSTEM exception wrapping in Flink code base

Hey Hong, Keep in mind that Flink 2.0 is also under discussion and breaking changes could be introduced -- lets just make sure there is real value in a cleaner exception hierarchy (which I believe there is). Cheers, Panagiotis On Sat, Jun 10, 2023 at 4:22 AM Teoh, Hong wrote: > Thanks for the

Re: [DISCUSS] FLIP 295: Support persistence of Catalog configuration and asynchronous registration

hi, Hang Thanks for your reply, Make sense to me, I updated the FLIP. Best, Feng On Fri, Jun 9, 2023 at 3:34 PM Hang Ruan wrote: > Hi, Feng. > > I reviewed this FLIP again and found some little places that may need to > optimize. > > 1. `CatalogDescriptor` may need a private constructor.

Re: [DISCUSS] FLIP-308: Support Time Travel In Batch Mode

Thanks Benchao and Leonard. 'Implicitly type conversion' makes sense to me. I will emphasize the 'Implicitly type conversion' in the document. Best, Feng On Sat, Jun 10, 2023 at 10:11 AM Benchao Li wrote: > Thanks Leonard for the input, "Implicitly type conversion" way sounds good > to me.

Re: [DISCUSS] FLIP-316: Introduce SQL Driver

Sorry for the late reply. I am in favor of introducing such a built-in resource localization mechanism based on Flink FileSystem. Then FLINK-28915[1] could be the second step which will download the jars and dependencies to the JobManager/TaskManager local directory before working. The first step

Re: [VOTE] FLIP-315: Support Operator Fusion Codegen for Flink SQL

Hi, all. FLIP-315 [1] has been accepted. There are 5 binding votes, 1 non-binding votes: - Jark Wu(binding) - Jingsong Li (binding) - Benchao Li (binding) - Weijie Guo(binding) - Jing Ge(binding) - Aitozi (non-binding) Thanks everyone. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-31