----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/45136/ -----------------------------------------------------------
(Updated March 22, 2016, 12:43 a.m.) Review request for samza, Navina Ramesh, Jagadish Venkatraman, and Yi Pan (Data Infrastructure). Summary (updated) ----------------- SAMZA-905 Host Affinity - State restore doesn't work if the previous shutdown was uncontrolled Repository: samza Description ------- Add continuous checkpointing. The offset file is now written on each commit Diffs ----- samza-core/src/main/scala/org/apache/samza/storage/TaskStorageManager.scala 422799a099dd391a50f934fe65d5b37471264af6 samza-core/src/test/scala/org/apache/samza/storage/TestTaskStorageManager.scala f08e8ddd6fc3b2cbf4ca195f22049d368abe6e62 Diff: https://reviews.apache.org/r/45136/diff/ Testing ------- New unit tests and a test job. With the test job set to autocommit, I was able to see the OFFSET file get written every commit. Thanks, Jake Maes
