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

Posted to commits@samza.apache.org by bh...@apache.org on 2020/09/02 22:10:52 UTC

[samza] branch master updated (a66fcd1 -> d689fd2)

This is an automated email from the ASF dual-hosted git repository.

bharathkk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git.


    from a66fcd1  SAMZA-2585: Modify shutdown sequence to handle orphaned AMs (#1422)
     add d689fd2  SAMZA-2584: Refactor ClusterBasedJobCoordinator (#1424)

No new revisions were added by this update.

Summary of changes:
 .../clustermanager/ClusterBasedJobCoordinator.java | 153 -----------------
 .../ClusterBasedJobCoordinatorRunner.java          | 188 +++++++++++++++++++++
 .../TestClusterBasedJobCoordinator.java            |  10 +-
 .../TestClusterBasedJobCoordinatorRunner.java      |  74 ++++++++
 .../apache/samza/util/TestSplitDeploymentUtil.java |  16 +-
 samza-shell/src/main/bash/run-jc.sh                |   2 +-
 6 files changed, 276 insertions(+), 167 deletions(-)
 create mode 100644 samza-core/src/main/java/org/apache/samza/clustermanager/ClusterBasedJobCoordinatorRunner.java
 create mode 100644 samza-core/src/test/java/org/apache/samza/clustermanager/TestClusterBasedJobCoordinatorRunner.java