This is an automated email from the ASF dual-hosted git repository.
saniljain15 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git
The following commit(s) were added to refs/heads/master by this push:
new 78c50e7 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)
78c50e7 is described below
commit 78c50e7ae5b4127ff4cc7a53f322f428c4b52323
Author: Sanil Jain <[email protected]>
AuthorDate: Tue Mar 30 18:24:44 2021 -0700
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)
---
.../src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java | 2 ++
1 file changed, 2 insertions(+)
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 @@ public class ContainerLaunchUtil {
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();
}