Re: Need help in creating Flink Streaming s3 Job for multiple path reader one by one

Hi @ches...@apache.org , Thanks for your support, it was really helpful. Do you know the list of directories when you submit the job? [Yes we do have] The impletemation is progress and will get back to you if any further challenges we may face. Appreciate your support in this regard. Regards, Sa

Re: Dynamic Scaling: State Sharding

So what is the state of dynamic scaling (non static, set by the user in the code) for SLA gurantees now, is it already included in FLink, and is it still necessaru to stop/restart the job for dynamic scaling. Thanks. -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/

[ANNOUNCE] New PMC member: Zhu Zhu

Hi all! I'm very happy to announce that Zhu Zhu has joined the Flink PMC! Zhu is helping the community a lot with creating and validating releases, contributing to FLIP discussions and good code contributions to the scheduler and related components. Congratulations and welcome Zhu Zhu! Regards,

Re: [VOTE] FLIP-144: Native Kubernetes HA for Flink

+1 Best, tison. Till Rohrmann 于2020年10月2日周五 下午6:27写道： > +1 (binding) > > Cheers, > Till > > On Fri, Oct 2, 2020 at 3:13 AM Yang Wang wrote: > > > Hi, all > > > > > > After the discussion in [1], I would like to open a voting thread for > > FLIP-144 [2], > > which proposes to add a new native

[jira] [Created] (FLINK-19500) Using canal-json,debezium-json,maxwell-json serialization, The DELETE semantics should be interpreted.

CaoZhen created FLINK-19500: --- Summary: Using canal-json,debezium-json,maxwell-json  serialization, The DELETE semantics should be interpreted. Key: FLINK-19500 URL: https://issues.apache.org/jira/browse/FLINK-19500