----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/17917/ -----------------------------------------------------------
Review request for samza. Repository: samza Description ------- protect the checkpoint serde from multiple offsets that map to the same system stream make task instance track offsets purely by SystemStream Diffs ----- samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala b30dd27951aee39ef279d88f470cc998eac49e9c samza-core/src/main/scala/org/apache/samza/serializers/CheckpointSerde.scala 574c58401647cf6fde5ca01d580d9d92ae01b188 samza-core/src/test/scala/org/apache/samza/container/TestTaskInstance.scala PRE-CREATION samza-core/src/test/scala/org/apache/samza/serializers/TestCheckpointSerde.scala PRE-CREATION Diff: https://reviews.apache.org/r/17917/diff/ Testing ------- Thanks, Chris Riccomini
