#!/bin/bash
#export JAVA_HOME=/usr/local/java/
export JAVA_HOME=/usr/local/jdk-11.0.20/
#export FLINK_ENV_JAVA_OPTS="-Xloggc:/data/soft/flink/flink-1.16.1/jvm-logs/gc.log -XX:+PrintGCDetails -XX:-OmitStackTraceInFastThrow -XX:+PrintGCTimeStamps -XX:+PrintGCDateStamps -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=20 -XX:GCLogFileSize=20m"
export FLINK_ENV_JAVA_OPTS="-Dfile.encoding=UTF-8 -Djava.io.tmpdir=/data/soft/flink/flink-1.17.1/tmp"
rm -rf log/*
./bin/stop-cluster.sh
./bin/stop-cluster.sh
./bin/start-cluster.sh
sleep 20
nohup ./bin/flink run ../jars-17.1/flink-cdc-kafka-source-task-v3.0.jar te 369 skip-redis > log/cdc-kafka-source.log &
sleep 1
nohup ./bin/flink run ../jars-17.1/flink-cdc-kafka-source-task-v3.0.jar te 370 skip-redis > log/cdc-kafka-source-shopping.log &
sleep 1
nohup ./bin/flink run ../jars-17.1/tenant-data-etc-task-v2.0.jar test2 user > log/log-flink-user.log &
sleep 1
nohup ./bin/flink run ../jars-17.1/tenant-data-etc-task-v2.0.jar test2 others > log/log-flink-others.log &
sleep 1
nohup ./bin/flink run ../jars-17.1/tenant-data-etc-task-v2.0.jar test2 company > log/log-flink-company.log &
sleep 1
nohup ./bin/flink run ../jars-17.1/tenant-data-etc-task-v2.0.jar test2 employees > log/log-flink-employees.log &
sleep 1
nohup ./bin/flink run ../jars-17.1/tenant-data-etc-task-v2.0.jar test2 user-credential-details > log/log-flink-user-credential-details.log &
sleep 1
nohup ./bin/flink run ../jars-17.1/tenant-data-etc-task-v2.0.jar test2 shopping-account > log/shopping-account.log &
sleep 1
nohup ./bin/flink run ../jars-17.1/tenant-data-etc-task-v2.0.jar test2 shopping-product > log/shopping-product.log &
sleep 1
nohup ./bin/flink run ../jars-17.1/tenant-data-etc-table-task-v2.0.jar test2 shopping-order-webhook-v5> log/log-tenant-data-etc-table-task.log &
echo done