[ https://issues.apache.org/jira/browse/FLINK-4625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stephan Ewen resolved FLINK-4625. --------------------------------- Resolution: Fixed Fixed via 5066125f9a377d232f77f6fbcac3c22ebea66b39 > 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)