Hi Alex, - Should this reusable ProcessFunction filter out data or simply tag > them? For example, filtering data for green deployments would be > suitable > in the case of Async IO outputs.
Could you clarify the idea a bit more, it is not quite clear what you mean. - Should we also modify the Source API to allow it to provide COLOR to > the Source functions? This could be used, for instance, to generate a > different groupId for Kafka. That is a good point, and can definitely be useful, especially given the concerns that both jobs can consume at significantly different rates, particularly if the blue job is backpressured by the sink. Best, Alex On Mon, 9 Dec 2024 at 14:36, Yang LI <yang.hunter...@gmail.com> wrote: > Hello Sergio and Jose, > > Apologies for jumping into the conversation. I’m very interested in what > you’ve learned about blue/green Flink deployments. I’m currently working on > a project aimed at achieving no-downtime Flink deployments, so your > insights would be highly valuable. > > Thank you, > Yang >
