File tree 2 files changed +0
-3
lines changed
flink-contrib/docker-flink
2 files changed +0
-3
lines changed Original file line number Diff line number Diff line change @@ -32,7 +32,6 @@ if [ "${CMD}" == "--help" -o "${CMD}" == "-h" ]; then
32
32
exit 0
33
33
elif [ " ${CMD} " == " ${JOB_CLUSTER} " -o " ${CMD} " == " ${TASK_MANAGER} " ]; then
34
34
echo " Starting the ${CMD} "
35
- echo " config file: " && grep ' ^[^\n#]' $FLINK_HOME /conf/flink-conf.yaml
36
35
37
36
if [ " ${CMD} " == " ${TASK_MANAGER} " ]; then
38
37
exec $FLINK_HOME /bin/taskmanager.sh start-foreground " $@ "
Original file line number Diff line number Diff line change @@ -29,15 +29,13 @@ elif [ "$1" == "jobmanager" ]; then
29
29
echo " Starting Job Manager"
30
30
sed -i -e " s/jobmanager.rpc.address: localhost/jobmanager.rpc.address: ${JOB_MANAGER_RPC_ADDRESS} /g" $FLINK_HOME /conf/flink-conf.yaml
31
31
32
- echo " config file: " && grep ' ^[^\n#]' $FLINK_HOME /conf/flink-conf.yaml
33
32
exec $FLINK_HOME /bin/jobmanager.sh start-foreground
34
33
elif [ " $1 " == " taskmanager" ]; then
35
34
36
35
sed -i -e " s/jobmanager.rpc.address: localhost/jobmanager.rpc.address: ${JOB_MANAGER_RPC_ADDRESS} /g" $FLINK_HOME /conf/flink-conf.yaml
37
36
sed -i -e " s/taskmanager.numberOfTaskSlots: 1/taskmanager.numberOfTaskSlots: $( grep -c ^processor /proc/cpuinfo) /g" $FLINK_HOME /conf/flink-conf.yaml
38
37
39
38
echo " Starting Task Manager"
40
- echo " config file: " && grep ' ^[^\n#]' $FLINK_HOME /conf/flink-conf.yaml
41
39
exec $FLINK_HOME /bin/taskmanager.sh start-foreground
42
40
fi
43
41
You can’t perform that action at this time.
0 commit comments