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 2015/04/14 21:15:19 UTC
flink git commit: [scripts] Update error message for missing commands
of the jobmanager.sh script
Repository: flink
Updated Branches:
refs/heads/master cb34e976d -> 51a583adb
[scripts] Update error message for missing commands of the jobmanager.sh script
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/51a583ad
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/51a583ad
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/51a583ad
Branch: refs/heads/master
Commit: 51a583adbdddf0684eb417c5d56617d389c0d4c8
Parents: cb34e97
Author: Robert Metzger <rm...@apache.org>
Authored: Tue Apr 14 21:15:08 2015 +0200
Committer: Robert Metzger <rm...@apache.org>
Committed: Tue Apr 14 21:15:08 2015 +0200
----------------------------------------------------------------------
flink-dist/src/main/flink-bin/bin/jobmanager.sh | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/51a583ad/flink-dist/src/main/flink-bin/bin/jobmanager.sh
----------------------------------------------------------------------
diff --git a/flink-dist/src/main/flink-bin/bin/jobmanager.sh b/flink-dist/src/main/flink-bin/bin/jobmanager.sh
index 93e5ee3..273cdd3 100755
--- a/flink-dist/src/main/flink-bin/bin/jobmanager.sh
+++ b/flink-dist/src/main/flink-bin/bin/jobmanager.sh
@@ -79,7 +79,7 @@ case $STARTSTOP in
rotateLogFile $log
rotateLogFile $out
- echo Starting job manager
+ echo "Starting Job Manager"
$JAVA_RUN $JVM_ARGS ${FLINK_ENV_JAVA_OPTS} "${log_setting[@]}" -classpath "`manglePathList "$FLINK_JM_CLASSPATH:$INTERNAL_HADOOP_CLASSPATHS"`" org.apache.flink.runtime.jobmanager.JobManager --executionMode $EXECUTIONMODE --configDir "$FLINK_CONF_DIR" > "$out" 2>&1 < /dev/null &
echo $! > $pid
@@ -88,18 +88,18 @@ case $STARTSTOP in
(stop)
if [ -f $pid ]; then
if kill -0 `cat $pid` > /dev/null 2>&1; then
- echo Stopping job manager
+ echo "Stopping job manager"
kill `cat $pid`
else
- echo No job manager to stop
+ echo "No job manager to stop"
fi
else
- echo No job manager to stop
+ echo "No job manager to stop"
fi
;;
(*)
- echo Please specify start or stop
+ echo "Please specify 'start (cluster|local)' or stop"
;;
esac