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
