Increased timeouts for state tests. apache#6200 apache#6198

devinbost · Feb 3, 2020 · b7bc2a5 · b7bc2a5
1 parent 3f6e050
commit b7bc2a5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...egration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarStateTest.java b/...egration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarStateTest.java
@@ -116,7 +116,7 @@ public void testSourceState() throws Exception {
                 } catch (PulsarAdminException e) {
                     return false;
                 }
-            }, 10, 200);
+            }, 20, 400);
 
             SourceStatus status = admin.sources().getSourceStatus("public", "default", sourceName);
             assertEquals(status.getInstances().size(), 1);
@@ -173,7 +173,7 @@ public void testSinkState() throws Exception {
                 } catch (PulsarAdminException e) {
                     return false;
                 }
-            }, 10, 200);
+            }, 20, 400);
 
             SinkStatus status = admin.sinks().getSinkStatus("public", "default", sinkName);
             assertEquals(status.getInstances().size(), 1);