P19 23.07 online-configP19

1 files changed, 34 insertions, 0 deletions

diff --git a/MSH-PIC/flink/topology/completion/stop.sh b/MSH-PIC/flink/topology/completion/stop.sh
new file mode 100644
index 0000000..24e1a83
--- /dev/null
+++ b/MSH-PIC/flink/topology/completion/stop.sh
@@ -0,0 +1,34 @@
+#!/bin/bash
+
+#flink任务停止脚本
+source /etc/profile
+#加参数 per-job 或 session
+TASK_MODE="per-job"
+SESSION_CLUSTER="Flink session cluster"
+
+APPLICATION_ID=$(yarn application -list | grep "$SESSION_CLUSTER" | awk '{print $1}')
+
+function read_dir() {
+    for file in $(ls $1); do
+        if [ -d $1"/"$file ]; then
+            read_dir $1"/"$file
+        else
+            if [[ $TASK_MODE == "per-job" ]]; then
+                appid=$(yarn application -list | grep "$file" | awk '{print $1}')
+                yarn application -kill $appid
+                echo -e "\033[32mcancel $file\033[0m"
+
+            elif [[ -n $APPLICATION_ID && $TASK_MODE == "session" ]]; then
+                jobid=$(flink list | grep -v flink | grep "$file" | awk '{print $4}')
+                flink cancel $jobid
+                echo -e "\033[32mcancel $file\033[0m"
+            fi
+
+        fi
+
+    done
+}
+
+#读取第一个参数 为配置文件目录名
+read_dir $1
+