continue to use anyOf when logViaFnApi is enabled

apache · Dec 20, 2024 · f0e8c74 · f0e8c74
1 parent 13aeac5
commit f0e8c74
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java b/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java
@@ -415,7 +415,7 @@ private BeamFnApi.ProcessBundleDescriptor loadDescriptor(String id) {
       if (options.as(SdkHarnessOptions.class).getEnableLogViaFnApi()) {
         CompletableFuture.anyOf(control.terminationFuture(), logging.terminationFuture()).get();
       } else {
-        CompletableFuture.allOf(control.terminationFuture(), logging.terminationFuture()).get();
+        control.terminationFuture().get();
       }
       if (beamFnStatusClient != null) {
         beamFnStatusClient.close();