Fixing flaky test testCreateDatastreamHappyPathDefaultRetention (link…

…edin#854) Increasing the timeout before validating retention time.
vmaheshw · Mar 1, 2022 · 9e7b137 · 9e7b137
1 parent d0e7df7
commit 9e7b137
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/datastream-server-restli/src/test/java/com/linkedin/datastream/server/TestCoordinator.java b/datastream-server-restli/src/test/java/com/linkedin/datastream/server/TestCoordinator.java
@@ -2337,7 +2337,7 @@ private void validateRetention(Datastream stream, DatastreamResources resource,
     // Adding a sleep to simulate time required for topic metadata to be synced across all brokers of destination
     // kafka cluster.
     try {
-      Thread.sleep(2000);
+      Thread.sleep(5000);
     } catch (Exception e) {
     }