commit 78c50e7ae5b4127ff4cc7a53f322f428c4b52323
author Sanil Jain <sanil.jain15@gmail.com> Tue Mar 30 18:24:44 2021 -0700
committer GitHub <noreply@github.com> Tue Mar 30 18:24:44 2021 -0700
tree 70d3cecb15c94e86cfbc11e1dcbbb835c94f530b
parent 78e42325410c795482176c7e8d2effabd24de227

SAMZA-2644: ContainerLaunchUtil swallows exception and does not even log them if an exception occurs while setting up a Samza container or invoking run on it (#1487)

samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java

diff --git a/samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java b/samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java
index 8e9f83d..004c416 100644
--- a/samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java
+++ b/samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java
@@ -174,6 +174,8 @@
         log.error("Container stopped with Exception. Exiting process now.", containerRunnerException);
         System.exit(1);
       }
+    } catch (Throwable e) {
+      log.error("Container stopped with Exception. ", containerRunnerException);
     } finally {
       coordinatorStreamStore.close();
     }