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
网友评论