summaryrefslogtreecommitdiff
path: root/groot-bootstrap
diff options
context:
space:
mode:
authordoufenghu <[email protected]>2024-06-20 21:54:10 +0800
committerdoufenghu <[email protected]>2024-06-20 21:54:10 +0800
commit445f9f129ad07e04a3e087a93793d6ce5a47f341 (patch)
tree7e8fc7e67782a90f84eaa4f3abca070ddb160561 /groot-bootstrap
parent687f56833e01f1ba6b2e66ab5d7c53847fbfd6c4 (diff)
[Fix][docs] Fix some bootstrap errors
Diffstat (limited to 'groot-bootstrap')
-rw-r--r--groot-bootstrap/src/main/bin/stop.sh18
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"