[samza] branch elasticity-checkpoint-lastProcessedOffsets updated (2cda17424 -> 7f5b0dfd6)

[ra...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

rayman pushed a change to branch elasticity-checkpoint-lastProcessedOffsets
in repository https://gitbox.apache.org/repos/asf/samza.git


    from 2cda17424 SAMZA-2733: [Elasticity] Compute last processed offsets when container starts up using checkpoints from previous deploys when elasticity was enabled
     new 9e2b13b93 wip
     new c0138369b SAMZA-2734: [Elasticity] Update last processed offset after an envelope is finished processing when elasticity is enabled
     new d08546227 add test
     new 7f5b0dfd6 Merge pull request #1599 from lakshmi-manasa-g/elasticity-checkpoint-readWrite

The 2475 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../apache/samza/checkpoint/OffsetManager.scala    | 12 ++++++-
 .../org/apache/samza/system/SystemConsumers.scala  |  4 +--
 .../samza/checkpoint/TestOffsetManager.scala       | 41 ++++++++++++++++++++++
 3 files changed, 54 insertions(+), 3 deletions(-)