Flink常用操作命令

1、拷包到flink开发环境上，并在bin目录下执行

scp /home/pubtrans/jianhen/buslinecount-1.0-jar-with-dependencies.jar root@10.0.101.199:

cd /home/flink-1.4.0/bin

2、起服务

./flink run /root/buslinecount-1.0-jar-with-dependencies.jar

3、取消任务

./flink cancel jobId

4、停止集群服务

./stop_cluster.sh

5、启动集群服务

./start_cluster.sh

6、启动参数设置

--bootstrap.servers 10.0.10.224:14002,10.0.10.227:14002,10.0.10.228:14002 --group.id clouddispatch --dispatch.topic DISPATCH_33010001_FREQ --eta.topic FORECAST_330100