Fix a flaky test caused by race condition

apache · Feb 9, 2024 · 06490ef · 06490ef
1 parent ff272db
commit 06490ef
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/fn/data/BeamFnDataInboundObserverTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/fn/data/BeamFnDataInboundObserverTest.java
@@ -165,6 +165,7 @@ public void testCloseVisibleToAwaitCompletionCallerAndProducer() throws Exceptio
     Future<?> future2 =
         executor.submit(
             () -> {
+              Thread.sleep(500); // give the previous future some time to reach the inf while loop
               observer.close();
               return null;
             });