1 files changed, 40 insertions, 0 deletions
diff --git a/log-stream/start.sh b/log-stream/start.sh
new file mode 100644
index 0000000..a4d0ccf
--- /dev/null
+++ b/log-stream/start.sh
@@ -0,0 +1,40 @@
+#!/bin/bash
+#启动storm任务脚本
+source /etc/profile
+#任务jar所在目录
+BASE_DIR=`pwd`
+#primordial
+primordial='log-stream-doublewrite-22.04.jar'
+#jar name
+JAR_NAME='log-stream-doublewrite_tmp.jar'
+#并行度
+PARALLELISM=1
+
+yes | cp -r $primordial $JAR_NAME
+
+#cd $BASE_DIR
+jar -xvf $BASE_DIR/$JAR_NAME service_flow_config.properties
+function read_dir(){
+        for file in `ls $1` #注意此处这是两个反引号，表示运行系统命令
+ do
+        if [ -d $1"/"$file ] #注意此处之间一定要加上空格，否则会报错
+                then
+                  read_dir $1"/"$file
+                else
+	        num=`flink list | grep "$file" | wc -l`
+	       	if [ $num -eq "0" ];then
+       		cat $1$file > $BASE_DIR/service_flow_config.properties
+       		jar -uvf $BASE_DIR/$JAR_NAME service_flow_config.properties
+                flink run -d -c com.zdjizhi.topology.LogFlowWriteTopology -p $PARALLELISM $JAR_NAME $file
+                sleep 10
+                fi
+	fi
+done
+}
+if [ $# != 1 ];then
+    echo "usage: ./startall.sh [Configuration path]"
+    exit 1
+fi
+#读取第一个参数 为配置文件目录名称
+read_dir $1
+rm -rf $JAR_NAME