diff options
| author | doufenghu <[email protected]> | 2024-06-20 21:54:10 +0800 |
|---|---|---|
| committer | doufenghu <[email protected]> | 2024-06-20 21:54:10 +0800 |
| commit | 445f9f129ad07e04a3e087a93793d6ce5a47f341 (patch) | |
| tree | 7e8fc7e67782a90f84eaa4f3abca070ddb160561 /groot-bootstrap | |
| parent | 687f56833e01f1ba6b2e66ab5d7c53847fbfd6c4 (diff) | |
[Fix][docs] Fix some bootstrap errors
Diffstat (limited to 'groot-bootstrap')
| -rw-r--r-- | groot-bootstrap/src/main/bin/stop.sh | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/groot-bootstrap/src/main/bin/stop.sh b/groot-bootstrap/src/main/bin/stop.sh index 91e24b9..c68f27c 100644 --- a/groot-bootstrap/src/main/bin/stop.sh +++ b/groot-bootstrap/src/main/bin/stop.sh @@ -2,31 +2,31 @@ # Function to display usage display_usage() { - echo "Usage: $0 <DEPLOYMENT_MODE> <JOB_NAME>" + echo "Usage: $0 <DEPLOYMENT_MODE> <JOB_OR_YARN_APP_NAME>" echo "DEPLOYMENT_MODE: standalone, yarn-per-job, or yarn-session" } # Function to stop Flink jobs based on deployment mode stop_jobs() { case $1 in standalone) - "$FLINK_HOME"/bin/flink list -r -m "$FLINK_JOB_MANAGER_ADDRESS" | grep "$job_name" | awk '{print $4}' | while read -r jobId + "$FLINK_HOME"/bin/flink list -r -m "$FLINK_STANDALONE_JOB_MANAGER_ADDRESS" | grep "$job_or_yarn_app_name" | awk '{print $4}' | while read -r jobId do - "$FLINK_HOME"/bin/flink cancel "$jobId" -m "$FLINK_JOB_MANAGER_ADDRESS" + "$FLINK_HOME"/bin/flink cancel "$jobId" -m "$FLINK_STANDALONE_JOB_MANAGER_ADDRESS" echo "Stopped Flink job with JobID: $jobId" done ;; yarn-per-job) # Command to stop YARN applications for the specified Yarn cluster app name - yarn application -list -appStates RUNNING | grep "$job_name" | awk '{print $1}' | while read -r appId + yarn application -list -appStates RUNNING | grep "$job_or_yarn_app_name" | awk '{print $1}' | while read -r appId do yarn application -kill "$appId" echo "Stopped YARN application with ApplicationID: $appId" done ;; yarn-session) - "$FLINK_HOME"/bin/flink list -r -yid "$YARN_ADDRESS" | grep "$job_name" | awk '{print $4}' | while read -r jobId + "$FLINK_HOME"/bin/flink list -r -yid "$YARN_SESSION_CLUSTER_ID" | grep "$job_or_yarn_app_name" | awk '{print $4}' | while read -r jobId do - "$FLINK_HOME"/bin/flink cancel "$jobId" -yid "$YARN_ADDRESS" + "$FLINK_HOME"/bin/flink cancel "$jobId" -yid "$YARN_SESSION_CLUSTER_ID" echo "Stopped Flink job with JobID: $jobId" done ;; @@ -63,16 +63,16 @@ fi # Assigning input arguments to variables deployment_mode=$1 # standalone, yarn-per-job, or yarn-session -job_name=$2 # The Flink job name to stop +job_or_yarn_app_name=$2 # Standalone job name or YARN application name # Checking for empty input arguments -if [ -z "$deployment_mode" ] || [ -z "$job_name" ]; then +if [ -z "$deployment_mode" ] || [ -z "$job_or_yarn_app_name" ]; then display_usage exit 1 fi # Execute stop_jobs function with provided arguments -stop_jobs "$deployment_mode" "$job_name" +stop_jobs "$deployment_mode" "$job_or_yarn_app_name" |
