Skip to content

Commit

Permalink
[FLINK-18152][Depl] Fail fast in JM scripts if memory configuration f…
Browse files Browse the repository at this point in the history
…ailed

This closes apache#12521.
  • Loading branch information
azagrebin committed Jun 9, 2020
1 parent 4e24a8b commit 44acd50
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions flink-dist/src/main/flink-bin/bin/config.sh
Original file line number Diff line number Diff line change
Expand Up @@ -545,6 +545,12 @@ parseJmJvmArgsAndExportLogs() {
java_utils_output=$(runBashJavaUtilsCmd GET_JM_RESOURCE_PARAMS "${FLINK_CONF_DIR}" "${FLINK_BIN_DIR}/bash-java-utils.jar:$(findFlinkDistJar)" "$@")
logging_output=$(extractLoggingOutputs "${java_utils_output}")
jvm_params=$(extractExecutionResults "${java_utils_output}" 1)

if [[ $? -ne 0 ]]; then
echo "[ERROR] Could not get JVM parameters and dynamic configurations properly."
exit 1
fi

export JVM_ARGS="${JVM_ARGS} ${jvm_params}"

export FLINK_INHERITED_LOGS="
Expand Down

0 comments on commit 44acd50

Please sign in to comment.