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