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 cb63b275d SAMZA-2735: Support configurable command to run jc in Yarn
(#1600)
add 400d1972c SAMZA-2731: Add readAllCheckpoints to CheckpointManager and
implement for KafkaCheckpointManager
add 840233ae8 Merge pull request #1597 from
lakshmi-manasa-g/elasticity-kafka-readAllCheckpoints
No new revisions were added by this update.
Summary of changes:
.../apache/samza/checkpoint/CheckpointManager.java | 13 +++++++++
.../checkpoint/kafka/KafkaCheckpointManager.scala | 32 +++++++++++++++-------
.../kafka/TestKafkaCheckpointManager.java | 19 +++++++++++++
3 files changed, 54 insertions(+), 10 deletions(-)
