You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 14:19:58 UTC
[jira] [Created] (FLINK-5232) Add a Thread default uncaught
exception handler on the JobManager
Stephan Ewen created FLINK-5232:
-----------------------------------
Summary: Add a Thread default uncaught exception handler on the JobManager
Key: FLINK-5232
URL: https://issues.apache.org/jira/browse/FLINK-5232
Project: Flink
Issue Type: Sub-task
Components: JobManager
Reporter: Stephan Ewen
Fix For: 1.1.3
When some JobManager threads die because of uncaught exceptions, we should bring down the JobManager. If a thread dies from an uncaught exception, there is a high chance that the JobManager becomes dysfunctional.
The only sfae thing is to rely on the JobManager being restarted by YARN / Mesos / Kubernetes / etc.
I suggest to add this code to the JobManager launch:
{code}
Thread.setDefaultUncaughtExceptionHandler(new UncaughtExceptionHandler() {
@Override
public void uncaughtException(Thread t, Throwable e) {
try {
LOG.error("Thread {} died due to an uncaught exception. Killing process.", t.getName());
} finally {
Runtime.getRuntime().halt(-1);
}
}
});
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)