Stephan Ewen created FLINK-4625: ----------------------------------- Summary: Guard Flink processes against blocking shutdown hooks Key: FLINK-4625 URL: https://issues.apache.org/jira/browse/FLINK-4625 Project: Flink Issue Type: Improvement Components: Distributed Coordination Affects Versions: 1.1.2 Reporter: Stephan Ewen Assignee: Stephan Ewen Fix For: 1.2.0
Resource managers like YARN send the JVM the {{SIGTERM}} signal to kill the process, if it wants to terminate a process. With {{SIGTERM}}, the JVM shutdown hooks run, and may cause the process to freeze up on shutdown. Especially since all dependencies (like Hadoop) may install shutdown hooks (and do so), it is not in Flink's control to make sure all Shutdown hooks are well behaved. I propose to add a guard that forcibly terminates the JVM if clean shutdown does not succeed within a certain time (say five seconds). -- This message was sent by Atlassian JIRA (v6.3.4#6332)