stable test

xyuanlu · xyuanlu · commit c1419fa03c95 · 2020-11-04T15:34:28.000-08:00
diff --git a/helix-core/src/test/java/org/apache/helix/integration/TestZkCallbackHandlerLeak.java b/helix-core/src/test/java/org/apache/helix/integration/TestZkCallbackHandlerLeak.java
@@ -472,6 +472,8 @@ public void testCurrentStatePathLeakingByAsycRemoval() throws Exception {
       jobAccesor.setProperty(jobKey, cs);
     }
 
+    // verify new watcher is installed on the new node
+    Thread.sleep(5000);
     Map<String, Set<String>> listenersByZkPath = ZkTestHelper.getListenersByZkPath(ZK_ADDR);
     Assert.assertTrue(listenersByZkPath.keySet().contains(jobKey.getPath()));
     rpWatchPaths = ZkTestHelper.getZkWatch(rpManager.getZkClient());

Original file line number	Diff line number	Diff line change
`@@ -472,6 +472,8 @@ public void testCurrentStatePathLeakingByAsycRemoval() throws Exception {`
`472`	`472`	`jobAccesor.setProperty(jobKey, cs);`
`473`	`473`	`}`
`474`	`474`
	`475`	`+ // verify new watcher is installed on the new node`
	`476`	`+ Thread.sleep(5000);`
`475`	`477`	`Map<String, Set<String>> listenersByZkPath = ZkTestHelper.getListenersByZkPath(ZK_ADDR);`
`476`	`478`	`Assert.assertTrue(listenersByZkPath.keySet().contains(jobKey.getPath()));`
`477`	`479`	`rpWatchPaths = ZkTestHelper.getZkWatch(rpManager.getZkClient());`