[jira] [Created] (FLINK-29048) WatermarksWithIdleness does not work with FLIP-27 sources

2022-08-20 Thread Lee Y S (Jira)
Lee Y S created FLINK-29048: --- Summary: WatermarksWithIdleness does not work with FLIP-27 sources Key: FLINK-29048 URL: https://issues.apache.org/jira/browse/FLINK-29048 Project: Flink Issue Type: B

Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang

2022-08-20 Thread Yuan Mei
Congratulations Junhan! Best, Yuan On Sat, Aug 20, 2022 at 2:11 PM Danny Cranmer wrote: > Congratulations Junhan! Welcome to the team. > > On Sat, 20 Aug 2022, 03:01 yuxia, wrote: > > > Congratulations, Junhan! > > > > Best regards, > > Yuxia > > > > - 原始邮件 - > > 发件人: "Aitozi" > > 收件人

Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang

2022-08-20 Thread Yuan Mei
Congratulations, Lijie! Best, Yuan On Sat, Aug 20, 2022 at 2:12 PM Danny Cranmer wrote: > Congratulations Lijie! Welcome to the team. > > On Sat, 20 Aug 2022, 03:25 Yun Tang, wrote: > > > Congratulations, Lijie! > > > > > > Best > > Yun Tang > > > > From: Geng

[jira] [Created] (FLINK-29047) [4.1] Shade the Flink-Kubernetes Fabric8 dependency with org.apache.flink.shaded prefix

2022-08-20 Thread bo zhao (Jira)
bo zhao created FLINK-29047: --- Summary: [4.1] Shade the Flink-Kubernetes Fabric8 dependency with org.apache.flink.shaded prefix Key: FLINK-29047 URL: https://issues.apache.org/jira/browse/FLINK-29047 Project

Re: [DISCUSS] FLIP-256 Support Job Dynamic Parameter With Flink Rest Api

2022-08-20 Thread Zheng Yu Chen
@Gyula say that add a config for this but not expose it on the rest api is right when user start up session cluster,we can config (eg jobmanager.rest.api.submit.job.allow-reset-config = true/false) to controller this behavior Now we have an existing cluster, the admin configures checkpointing in

Re: [DISCUSS] FLIP-256 Support Job Dynamic Parameter With Flink Rest Api

2022-08-20 Thread Zheng Yu Chen
I don't think this is a good idea because it breaks the jar run api, this is just a job submit parameter, now a non-job parameter (overwriteFlinkConfiguration) is introduced. flinkConfiguration is just an extra extension, users can keep their submit job by original way Jing Ge 于2022年8月19日周五 07:0