nohup java -Xms1024m -Xmx1024m  -jar flink-data-webhook-task-3.2.jar com-prod 190 employee > flink-data-webhook-task-3.2-employee.log &
nohup java -Xms1024m -Xmx1024m  -jar flink-data-webhook-task-3.2.jar com-prod 191 purse-comm-logs > flink-data-webhook-task-3.2-purse-comm-logs.log &
nohup java -Xms1024m -Xmx1024m  -jar flink-data-webhook-task-3.2.jar com-prod 189 company-station > flink-data-webhook-task-3.2-company-station-person.log &

nohup java -Xms1024m -Xmx1024m  -jar flink-data-webhook-task-3.2.jar com-prod 194 sync-zizhan-employee-company-station-person > flink-data-webhook-task-3.2-sync-zizhan-employee-company-station-person.log &




nohup java -Xms4144m -Xmx4144m  -jar flink-cdc-kafka-source-task-3.2.jar com-prod 67 cdc-binlog-kafka-multiple-partition &> flink-cdc-kafka-source-task-3.2-multiple-partition.log &





nohup bin/zookeeper-server-start.sh config/zookeeper.properties &
nohup bin/kafka-server-start.sh config/server.properties &



nohup java -Xms1024m -Xmx1024m -jar flink-streaming-table-task-3.2.jar com-prod 194 table-company > flink-streaming-table-task-3.2-table-company.log &
nohup java -Xms3096m -Xmx3096m -jar flink-streaming-table-task-3.2.jar com-prod 195 table-employee > flink-streaming-table-task-3.2-table-employee.log &
nohup java -Xms1024m -Xmx1024m -jar flink-streaming-table-task-3.2.jar com-prod 196 table-station-person > flink-streaming-table-task-3.2-table-station-person.log &
nohup java -Xms7146m -Xms7146m -jar flink-streaming-table-task-3.2.jar com-prod 195 table-employee-section-np > flink-streaming-table-task-3.2-table-employee-section-np.log &


#可用 com-prod 2023-04-25
nohup java -jar flink-streaming-table-task-3.2.jar com-prod 195 table-employee-section-np > flink-streaming-table-task-3.2-table-employee-section-np.log &
nohup java -Xms800m -Xms800m -jar flink-streaming-table-task-3.2.jar com-prod 194 table-company-count-np > flink-streaming-table-task-3.2-table-company-count-np.log &
nohup java -Xms6144m -Xms6144m -jar flink-streaming-table-task-3.2.jar com-prod 195 table-employee-section-np > flink-streaming-table-task-3.2-table-employee-section-np.log &
nohup java -Xms800m -Xms800m -jar flink-streaming-table-task-3.2.jar com-prod 196 table-station-person-np > flink-streaming-table-task-3.2-table-station-person-count-np.log &


#单分区
nohup java -Xms5144m -Xmx5144m  -jar flink-cdc-kafka-source-task-3.2.jar com-prod 267 cdc-binlog-kafka-single-partition &> flink-cdc-kafka-source-task-3.2-single-partition.log &
nohup java -Xms3096m -Xmx3096m -jar flink-streaming-table-task-3.2.jar com-prod 295 table-employee-single-partition > flink-streaming-table-task-3.2-table-employee-single-partition.log &


nohup java -Xms1024m -Xmx1024m -jar flink-streaming-table-task-3.2.jar com-prod 294 table-company-single-partition > flink-streaming-table-task-3.2-table-company-single-partition.log &

#com 人-公司-驻勤: 直接推送到dispatch
nohup java -Xms2048m -Xmx2048m -jar flink-cdc-dispatch-task-3.2.jar com-prod 268 > log-flink-cdc-dispatch.log&