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
epMs) } } ``` -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Periodic-actions-tp5290.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Periodic actions

2016-03-03 Thread shikhar
l desiredSleepMs = interval.toMillis do { Thread.sleep(math.min(desiredSleepMs, 100)) } while (active && (System.currentTimeMillis() - startTimeMs) < desiredSleepMs) } } ``` -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/P