You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mb...@apache.org on 2015/08/28 00:16:32 UTC
flink git commit: [FLINK-2499] [scripts] Warning message for hosts
starting multiple daemons
Repository: flink
Updated Branches:
refs/heads/master 0807eec0c -> 91069d1f7
[FLINK-2499] [scripts] Warning message for hosts starting multiple daemons
Closes #1071
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/91069d1f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/91069d1f
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/91069d1f
Branch: refs/heads/master
Commit: 91069d1f73f6812548235614ed7f8442c39e5959
Parents: 0807eec
Author: mbalassi <mb...@apache.org>
Authored: Thu Aug 27 17:25:01 2015 +0200
Committer: mbalassi <mb...@apache.org>
Committed: Fri Aug 28 00:14:57 2015 +0200
----------------------------------------------------------------------
flink-dist/src/main/flink-bin/bin/flink-daemon.sh | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/91069d1f/flink-dist/src/main/flink-bin/bin/flink-daemon.sh
----------------------------------------------------------------------
diff --git a/flink-dist/src/main/flink-bin/bin/flink-daemon.sh b/flink-dist/src/main/flink-bin/bin/flink-daemon.sh
index 1fc110a..b2be148 100644
--- a/flink-dist/src/main/flink-bin/bin/flink-daemon.sh
+++ b/flink-dist/src/main/flink-bin/bin/flink-daemon.sh
@@ -83,6 +83,12 @@ case $STARTSTOP in
rotateLogFile $log
rotateLogFile $out
+ # Print a warning if daemons are already running on host
+ if [ -f $pid ]; then
+ count=$(wc -l $pid | awk '{print $1}')
+ echo "[WARNING] $count instance(s) of $DAEMON are already running on $HOSTNAME."
+ fi
+
echo "Starting $DAEMON daemon on host $HOSTNAME."
$JAVA_RUN $JVM_ARGS ${FLINK_ENV_JAVA_OPTS} "${log_setting[@]}" -classpath "`manglePathList "$FLINK_TM_CLASSPATH:$INTERNAL_HADOOP_CLASSPATHS"`" ${CLASS_TO_RUN} ${ARGS} > "$out" 2>&1 < /dev/null &
mypid=$!