----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35071/ -----------------------------------------------------------
(Updated June 15, 2015, noon) Review request for samza. Repository: samza Description ------- Fix for [SAMZA-572](https://issues.apache.org/jira/browse/SAMZA-572): In RunLoop commit() and window() are called immediately on startup. This patch fixes the problem by setting the lastCommitMs and lastWindowMs to clock() Diffs (updated) ----- samza-core/src/main/scala/org/apache/samza/container/RunLoop.scala e0c3e7e samza-core/src/test/scala/org/apache/samza/container/TestRunLoop.scala cec6477 Diff: https://reviews.apache.org/r/35071/diff/ Testing ------- Unit test added to verify that window() and commit() are not called immediately on startup. Thanks, József Márton Jung
