[samza] branch master updated (a962e135f -> 1ff98f3a5)

[ra...@apache.org]

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