#!/bin/bash
export JAVA_HOME=/usr/local/java/
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"
rm -rf log/*
./bin/stop-cluster.sh
./bin/stop-cluster.sh
./bin/start-cluster.sh
#nohup ./bin/flink run ../jars/flink-cdc-kafka-source-task-v2.0.jar te 370 > log/cdc-kafka-source.log&
nohup ./bin/flink run ../jars/tenant-data-etc-task-v2.0.jar test2 sync-same-table > log/log-flink-user.log&
echo done