samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From József Márton Jung <j.j...@levi9.com>
Subject Review Request 35071: SAMZA-572 SamzaContainer checkpoints and windows immediately on startup
Date Thu, 04 Jun 2015 14:42:16 GMT

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/35071/
-----------------------------------------------------------

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
-----

  samza-core/src/main/scala/org/apache/samza/container/RunLoop.scala 4c0faf6 
  samza-core/src/test/scala/org/apache/samza/container/TestRunLoop.scala 73ec2b5 

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


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message