Change level of initialization exception to error, make errors obvious (

apache#29078)
Polber · Oct 26, 2023 · 8b8af7f · 8b8af7f
1 parent ffb4332
commit 8b8af7f
Showing 1 changed file with 3 additions and 2 deletions.
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
@@ -384,9 +384,10 @@ private BeamFnApi.ProcessBundleDescriptor loadDescriptor(String id) {
       }
       processBundleHandler.shutdown();
     } catch (Exception e) {
-      System.out.println("Shutting down harness due to exception: " + e.toString());
+      LOG.error("Shutting down harness due to exception", e);
+      e.printStackTrace();
     } finally {
-      System.out.println("Shutting SDK harness down.");
+      LOG.info("Shutting SDK harness down.");
       executionStateSampler.stop();
       executorService.shutdown();
     }