Add extra wait to avoid intermittent failures in OwnershipCacheTest (a…

…pache#503)
ccf19881030 · Jun 20, 2017 · 02128c6 · 02128c6
1 parent e87d5f8
commit 02128c6
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/pulsar-broker/src/test/java/com/yahoo/pulsar/broker/namespace/OwnershipCacheTest.java b/pulsar-broker/src/test/java/com/yahoo/pulsar/broker/namespace/OwnershipCacheTest.java
@@ -201,6 +201,9 @@ public void testGetOwnedServiceUnit() throws Exception {
         } catch (NullPointerException npe) {
             // OK for not owned namespace
         }
+
+        Thread.sleep(500);
+
         // try to acquire, which will load the read-only cache
         NamespaceEphemeralData data1 = cache.tryAcquiringOwnership(testBundle).get();
         assertEquals(data1.getNativeUrl(), "pulsar://otherhost:8881");
@@ -238,6 +241,9 @@ public void testGetOwnedServiceUnits() throws Exception {
                 new NamespaceEphemeralData("pulsar://otherhost:8881", "pulsar://otherhost:8884",
                         "http://otherhost:8080", "https://otherhost:4443", false));
         assertTrue(cache.getOwnedBundles().isEmpty());
+
+        Thread.sleep(500);
+
         // try to acquire, which will load the read-only cache
         NamespaceEphemeralData data1 = cache.tryAcquiringOwnership(testBundle).get();
         assertEquals(data1.getNativeUrl(), "pulsar://otherhost:8881");