You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2014/07/22 12:40:57 UTC
[57/92] [abbrv] git commit: Change cluster shutdown order to avoid
heartbeat exceptions during shutdown on large clusters
Change cluster shutdown order to avoid heartbeat exceptions during shutdown on large clusters
Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/2f3c0b9a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/2f3c0b9a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/2f3c0b9a
Branch: refs/heads/travis_test
Commit: 2f3c0b9aef6b09f1b3ea755e68a4390e8656cc76
Parents: 4771efc
Author: Robert Metzger <rm...@apache.org>
Authored: Fri Jul 11 19:45:07 2014 +0200
Committer: Robert Metzger <rm...@apache.org>
Committed: Fri Jul 11 20:02:50 2014 +0200
----------------------------------------------------------------------
flink-dist/src/main/flink-bin/bin/stop-cluster.sh | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/2f3c0b9a/flink-dist/src/main/flink-bin/bin/stop-cluster.sh
----------------------------------------------------------------------
diff --git a/flink-dist/src/main/flink-bin/bin/stop-cluster.sh b/flink-dist/src/main/flink-bin/bin/stop-cluster.sh
index eb8197b..50bf6e6 100755
--- a/flink-dist/src/main/flink-bin/bin/stop-cluster.sh
+++ b/flink-dist/src/main/flink-bin/bin/stop-cluster.sh
@@ -34,8 +34,6 @@ if [ ! -f "$HOSTLIST" ]; then
exit 1
fi
-# cluster mode, stop the job manager locally and stop the task manager on every slave host
-"$FLINK_BIN_DIR"/jobmanager.sh stop
GOON=true
while $GOON
@@ -46,3 +44,6 @@ do
ssh -n $FLINK_SSH_OPTS $HOST -- "nohup /bin/bash $FLINK_BIN_DIR/taskmanager.sh stop &"
fi
done < $HOSTLIST
+
+# cluster mode, stop the job manager locally and stop the task manager on every slave host
+"$FLINK_BIN_DIR"/jobmanager.sh stop