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(-)
