You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@helix.apache.org by jx...@apache.org on 2022/03/31 23:18:32 UTC

[helix] branch master updated: auto Exit MM for auto EMM test (#2003)

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

jxue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/helix.git


The following commit(s) were added to refs/heads/master by this push:
     new 03af78c  auto Exit MM for auto EMM test (#2003)
03af78c is described below

commit 03af78cec03dda07918aab65acf1a9b7200cebc8
Author: xyuanlu <xy...@gmail.com>
AuthorDate: Thu Mar 31 16:18:25 2022 -0700

    auto Exit MM for auto EMM test (#2003)
---
 .../TestClusterInMaintenanceModeWhenReachingOfflineInstancesLimit.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/helix-core/src/test/java/org/apache/helix/integration/rebalancer/TestClusterInMaintenanceModeWhenReachingOfflineInstancesLimit.java b/helix-core/src/test/java/org/apache/helix/integration/rebalancer/TestClusterInMaintenanceModeWhenReachingOfflineInstancesLimit.java
index fae1b31..dfc98a8 100644
--- a/helix-core/src/test/java/org/apache/helix/integration/rebalancer/TestClusterInMaintenanceModeWhenReachingOfflineInstancesLimit.java
+++ b/helix-core/src/test/java/org/apache/helix/integration/rebalancer/TestClusterInMaintenanceModeWhenReachingOfflineInstancesLimit.java
@@ -99,6 +99,7 @@ public class TestClusterInMaintenanceModeWhenReachingOfflineInstancesLimit exten
     ConfigAccessor configAccessor = new ConfigAccessor(_gZkClient);
     ClusterConfig clusterConfig = configAccessor.getClusterConfig(CLUSTER_NAME);
     clusterConfig.setMaxOfflineInstancesAllowed(_maxOfflineInstancesAllowed);
+    clusterConfig.setNumOfflineInstancesForAutoExit(0);
     configAccessor.setClusterConfig(CLUSTER_NAME, clusterConfig);
 
     for (int i = 0; i < 3; i++) {
@@ -190,7 +191,7 @@ public class TestClusterInMaintenanceModeWhenReachingOfflineInstancesLimit exten
       return ms != null && ms.getReason() != null;
     }, TestHelper.WAIT_DURATION);
     Assert.assertTrue(result);
-    
+
     // Verify there is rebalance error logged
     checkForRebalanceError(true);
   }