commit fafeb0669fd5ec3a629ebfb9a168870bedd1807c
author xyuanlu <xyuanlu@gmail.com> Thu Jun 01 15:55:21 2023 -0700
committer xyuanlu <xyuanlu@gmail.com> Fri Jun 02 09:53:28 2023 -0700
tree 80038041f56971191250577f9263f1704a103241
parent da9274c7dba30ab316a67869ffe35f3cac9309a8

Change undetermined check in unit test TestZooKeeperConnection(#2516)

zookeeper-api/src/test/java/org/apache/helix/zookeeper/impl/TestZooKeeperConnection.java

diff --git a/zookeeper-api/src/test/java/org/apache/helix/zookeeper/impl/TestZooKeeperConnection.java b/zookeeper-api/src/test/java/org/apache/helix/zookeeper/impl/TestZooKeeperConnection.java
index bdcb2a6..0ea8524 100644
--- a/zookeeper-api/src/test/java/org/apache/helix/zookeeper/impl/TestZooKeeperConnection.java
+++ b/zookeeper-api/src/test/java/org/apache/helix/zookeeper/impl/TestZooKeeperConnection.java
@@ -53,10 +53,11 @@
       _zk.writeData(path, ("datat"+i).getBytes(), -1);
       _zk.create(path+"/c2_" +i, null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
     }
+    System.out.println("testPersistWatcher: rafter register one time listener, original listener received event count: " + get_count[0]);
+    // total number of event is 400. We will miss event now
     Assert.assertTrue(TestHelper.verify(() -> {
-          return (get_count[0].get() == 202);
-        }, TestHelper.WAIT_DURATION));
-    System.out.println("testPersistWatcher received event count: " + get_count[0]);
+      return (get_count[0].get() >= 202 & get_count[0].get() < 400);
+    }, TestHelper.WAIT_DURATION));
     zkClient.close();
   }
 
@@ -87,10 +88,11 @@
       _zk.writeData(path, ("datat"+i).getBytes(), -1);
       _zk.create(path+"/c2_" +i, null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
     }
+    System.out.println("testRecursivePersistWatcherWithOneTimeWatcher: after register one time listener, original listener received event count: " + get_count[0]);
+    // total number of event is 500. We will miss event now
     Assert.assertTrue(TestHelper.verify(() -> {
-      return (get_count[0].get()== 302);
+      return (get_count[0].get() >= 302 && get_count[0].get() < 500);
     }, TestHelper.WAIT_DURATION));
-    System.out.println("testPersistWatcher received event count: " + get_count[0]);
     zkClient.close();
   }