1 files changed, 34 insertions, 0 deletions
diff --git a/TWA-PIC/flink/topology/relationship-gtpc-user/stop.sh b/TWA-PIC/flink/topology/relationship-gtpc-user/stop.sh
new file mode 100644
index 0000000..3657871
--- /dev/null
+++ b/TWA-PIC/flink/topology/relationship-gtpc-user/stop.sh
@@ -0,0 +1,34 @@
+#!/bin/bash
+
+#flink任务停止脚本
+source /etc/profile
+#加参数 per-job 或 per-job
+TASK_MODE="per-job"
+SESSION_CLUSTER="Flink per-job 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 == "per-job" ]]; 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
+