diff --git a/flink-dist/src/main/flink-bin/bin/config.sh b/flink-dist/src/main/flink-bin/bin/config.sh index d73b22037b99769d39a73190285f6a8033391be4..66f0d5b46c651001ffdd361fb6bd6693e1367129 100755 --- a/flink-dist/src/main/flink-bin/bin/config.sh +++ b/flink-dist/src/main/flink-bin/bin/config.sh @@ -391,7 +391,7 @@ rotateLogFilesWithPrefix() { dir=$1 prefix=$2 while read -r log ; do - rotateLogFile $log + rotateLogFile "$log" # find distinct set of log file names, ignoring the rotation number (trailing dot and digit) done < <(find "$dir" ! -type d -path "${prefix}*" | sed -E s/\.[0-9]+$// | sort | uniq) } 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 8bb6f0b5ac404e43e1d553e1bada292639492ce0..e897a490cd1809f93119b238282a81ab529afe75 100644 --- a/flink-dist/src/main/flink-bin/bin/flink-daemon.sh +++ b/flink-dist/src/main/flink-bin/bin/flink-daemon.sh @@ -97,7 +97,7 @@ case $STARTSTOP in (start) # Rotate log files - rotateLogFilesWithPrefix $FLINK_LOG_DIR $FLINK_LOG_PREFIX + rotateLogFilesWithPrefix "$FLINK_LOG_DIR" "$FLINK_LOG_PREFIX" # Print a warning if daemons are already running on host if [ -f $pid ]; then diff --git a/flink-dist/src/main/flink-bin/bin/taskmanager.sh b/flink-dist/src/main/flink-bin/bin/taskmanager.sh index b16abc9340f1dc7268417eea3f0da178d3a2b4aa..ba4fe1d78ba393d7aad8a2698bbb877f365edc8d 100755 --- a/flink-dist/src/main/flink-bin/bin/taskmanager.sh +++ b/flink-dist/src/main/flink-bin/bin/taskmanager.sh @@ -75,11 +75,9 @@ fi if [[ $STARTSTOP == "start-foreground" ]]; then exec "${FLINK_BIN_DIR}"/flink-console.sh taskmanager "${args[@]}" else - TM_COMMAND="${FLINK_BIN_DIR}/flink-daemon.sh $STARTSTOP taskmanager ${args[@]}" - if [[ $FLINK_TM_COMPUTE_NUMA == "false" ]]; then # Start a single TaskManager - $TM_COMMAND + "${FLINK_BIN_DIR}"/flink-daemon.sh $STARTSTOP taskmanager "${args[@]}" else # Example output from `numactl --show` on an AWS c4.8xlarge: # policy: default @@ -91,7 +89,7 @@ else read -ra NODE_LIST <<< $(numactl --show | grep "^nodebind: ") for NODE_ID in "${NODE_LIST[@]:1}"; do # Start a TaskManager for each NUMA node - numactl --membind=$NODE_ID --cpunodebind=$NODE_ID -- $TM_COMMAND + numactl --membind=$NODE_ID --cpunodebind=$NODE_ID -- "${FLINK_BIN_DIR}"/flink-daemon.sh $STARTSTOP taskmanager "${args[@]}" done fi fi