This is an automated email from the ASF dual-hosted git repository.
rayman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git
from a962e135f Merge pull request #1603 from
lakshmi-manasa-g/elasticity-SSPKeyDeser
new 2cda17424 SAMZA-2733: [Elasticity] Compute last processed offsets when
container starts up using checkpoints from previous deploys when elasticity was
enabled
new 58af35811 handle null in some edge cases and add tests for these edge
cases
new cea7ab9db use elasticity checkpoints only if
job.elasticity.checkpoints.enabled=true
new 603cfaacb remove new config and add one more unit test and address
comments
new be7e0142a empty commit to trigger travis
new 1ff98f3a5 Merge pull request #1598 from
lakshmi-manasa-g/elasticity-checkpoint-lastProcessedOffsets
The 2490 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:
.../java/org/apache/samza/config/JobConfig.java | 1 -
.../samza/elasticity/util/ElasticityUtils.java | 493 +++++++++++++++++++++
.../samza/elasticity/util/TaskNameComponents.java | 84 ++++
.../apache/samza/checkpoint/OffsetManager.scala | 26 +-
.../samza/elasticity/util/TestElasticityUtils.java | 435 ++++++++++++++++++
5 files changed, 1030 insertions(+), 9 deletions(-)
create mode 100644
samza-core/src/main/java/org/apache/samza/elasticity/util/ElasticityUtils.java
create mode 100644
samza-core/src/main/java/org/apache/samza/elasticity/util/TaskNameComponents.java
create mode 100644
samza-core/src/test/java/org/apache/samza/elasticity/util/TestElasticityUtils.java
