----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/28269/ -----------------------------------------------------------
(Updated Nov. 20, 2014, 10:51 p.m.) Review request for samza. Changes ------- Whitespace adjustments; test. Repository: samza Description ------- Fixes SAMZA-461; defaults to the upcoming offset when the stream is empty. Diffs (updated) ----- samza-core/src/main/scala/org/apache/samza/checkpoint/OffsetManager.scala 80c8d0e samza-core/src/test/scala/org/apache/samza/checkpoint/TestOffsetManager.scala a79ecca Diff: https://reviews.apache.org/r/28269/diff/ Testing (updated) ------- Added a test for the defaulting behaviour. This also fixes the bug in my (external) integration tests. Thanks, Ben Kirwin
