Flink執行job兩種方式

1、直接執行方式

#! /bin/bash

#首先啟動nc
# nc -lk 5000 （注意，請在另一個窗口啟動）

#執行flink任務

../bin/flink run demo.jar -d &

2、指定checkpoint點執行

#! /bin/bash

#首先啟動nc
# nc -lk 5000 （注意，請在另一個窗口啟動）

#執行flink任務

../bin/flink run  -s hdfs://localhost:8020/flink/checkpoint/87f1df5431dece4e78c5e0269d3ae1f5/chk-12/_metadata -c com.example.demo.flink.TestCheckpoint demo.jar -d &