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