[FLINK-24353][scripts] Respect dynamic configurations when calculatin…

…g memory sizes. This closes apache#17335
mbalassi · Sep 23, 2021 · 1d564a9 · 1d564a9
1 parent 038f78f
commit 1d564a9
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/flink-dist/src/main/flink-bin/bin/config.sh b/flink-dist/src/main/flink-bin/bin/config.sh
@@ -526,7 +526,7 @@ extractLoggingOutputs() {
 
 parseResourceParamsAndExportLogs() {
  local cmd=$1
- java_utils_output=$(runBashJavaUtilsCmd ${cmd} "${FLINK_CONF_DIR}" "${FLINK_BIN_DIR}/bash-java-utils.jar:$(findFlinkDistJar)" "$@")
+ java_utils_output=$(runBashJavaUtilsCmd ${cmd} "${FLINK_CONF_DIR}" "${FLINK_BIN_DIR}/bash-java-utils.jar:$(findFlinkDistJar)" "${@:2}")
  logging_output=$(extractLoggingOutputs "${java_utils_output}")
  params_output=$(extractExecutionResults "${java_utils_output}" 2)
 
@@ -552,9 +552,9 @@ logs: $logging_output
 }
 
 parseJmArgsAndExportLogs() {
- parseResourceParamsAndExportLogs GET_JM_RESOURCE_PARAMS
+ parseResourceParamsAndExportLogs GET_JM_RESOURCE_PARAMS "$@"
 }
 
 parseTmArgsAndExportLogs() {
- parseResourceParamsAndExportLogs GET_TM_RESOURCE_PARAMS
+ parseResourceParamsAndExportLogs GET_TM_RESOURCE_PARAMS "$@"
 }