flink使用命令開始、停止任務

 

進行flink的安裝目錄

 

動態上傳jar包啟動job

 ./bin/flink run -c  com.test.CountMain -P 3 Test-1. 0-SNAPSHOT.jar --host localhost --port 6379

 

參數說明

 -c : 后面的jar包里面的main類的路徑

-P ：是執行的線程數目 

Test-1. 0-SNAPSHOT.jar  這個是jar包名稱

 --host localhost --port 6379 是設置的參數 是否需要根據自己的來

 

 

查詢所有任務

./bin/flink list

 

 

 紅框就是對應的jobId

 

 

停止任務

./bin/flink cancel 74e2ce94692adc28c6f3c7a156f96694

后面跟着要停止的jobID