Skip to content

Commit

Permalink
[hotfix] Remove unused cluster parameter from flink-contrib/docker-fl…
Browse files Browse the repository at this point in the history
…ink/docker-entrypoint.sh
  • Loading branch information
tillrohrmann committed Oct 5, 2018
1 parent 833d89e commit f4aa31c
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion flink-contrib/docker-flink/docker-entrypoint.sh
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ elif [ "$1" == "jobmanager" ]; then
sed -i -e "s/jobmanager.rpc.address: localhost/jobmanager.rpc.address: ${JOB_MANAGER_RPC_ADDRESS}/g" $FLINK_HOME/conf/flink-conf.yaml

echo "config file: " && grep '^[^\n#]' $FLINK_HOME/conf/flink-conf.yaml
exec $FLINK_HOME/bin/jobmanager.sh start-foreground cluster
exec $FLINK_HOME/bin/jobmanager.sh start-foreground
elif [ "$1" == "taskmanager" ]; then

sed -i -e "s/jobmanager.rpc.address: localhost/jobmanager.rpc.address: ${JOB_MANAGER_RPC_ADDRESS}/g" $FLINK_HOME/conf/flink-conf.yaml
Expand Down

0 comments on commit f4aa31c

Please sign in to comment.