Repository: flink Updated Branches: refs/heads/master 0ccab95e7 -> 4e592324a
[FLINK-3100] signal handler prints error on normal shutdown of cluster Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4e592324 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4e592324 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4e592324 Branch: refs/heads/master Commit: 4e592324a73ec9af4762a8bb26176d2258dbf720 Parents: 0ccab95 Author: Maximilian Michels <m...@apache.org> Authored: Wed Dec 2 17:39:49 2015 +0100 Committer: Maximilian Michels <m...@apache.org> Committed: Wed Dec 2 17:44:23 2015 +0100 ---------------------------------------------------------------------- .../main/java/org/apache/flink/runtime/util/SignalHandler.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/4e592324/flink-runtime/src/main/java/org/apache/flink/runtime/util/SignalHandler.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/util/SignalHandler.java b/flink-runtime/src/main/java/org/apache/flink/runtime/util/SignalHandler.java index 0f85e71..1b60719 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/util/SignalHandler.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/util/SignalHandler.java @@ -45,8 +45,9 @@ public class SignalHandler { */ @Override public void handle(Signal signal) { - LOG.error("RECEIVED SIGNAL " + signal.getNumber() + ": SIG" + signal.getName()); - LOG.error("This JVM will shut down because it was killed from the outside."); + LOG.info("RECEIVED SIGNAL {}: SIG{}. Shutting down as requested.", + signal.getNumber(), + signal.getName()); prevHandler.handle(signal); } }
