Re: Periodic actions

2016-03-04 Thread shikhar
Wow that's embarassing :D That was indeed the issue -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Periodic-actions-tp5290p5304.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: Periodic actions

2016-03-03 Thread Chesnay Schepler
could the problem be as simple as var active being never true? On 04.03.2016 03:08, shikhar wrote: I am trying to have my job also run a periodic action by using a custom source that emits a dummy element periodically and a sink that executes the callback, as shown in the code below. However as