----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/28269/ -----------------------------------------------------------
Review request for samza. Repository: samza Description ------- Fixes SAMZA-461; defaults to the upcoming offset when the stream is empty. Diffs ----- samza-core/src/main/scala/org/apache/samza/checkpoint/OffsetManager.scala 80c8d0e Diff: https://reviews.apache.org/r/28269/diff/ Testing ------- Passes the existing test suite, and fixes the bug in my (external) integration tests. Thanks, Ben Kirwin
