Hi Community,

We are working on adding output time independent of firing specification
for all timers. Currently, we have set the required holds for Direct Runner
and Dataflow. We need to do the same for Flink as well. Need some
assistance in how we can achieve this.


Watermark holds for Flink to set:
https://github.com/apache/beam/pull/9677#discussion_r346541589


*Thanks & Regards*


<http://venturedive.com/>

*Rehman Murad Ali*
Software Engineer
Mobile: +92 3452076766
Skype: rehman.muradali

Reply via email to