You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by ra...@apache.org on 2022/04/27 22:09:38 UTC

[samza] branch master updated (cb63b275d -> 840233ae8)

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