DockerDesktop搭建Flink集群：命令行提交jar包
迪丽瓦拉
2025-05-30 20:45:49
0次
一般提交任务都是在WEBUI中，可是如果想用命令行提交该怎么办？
尤其我这个是DockerDesktop，又该怎么弄呢？和正常的Docker一样吗？
是的，一样的。
我先将需要提交的jar包放进jobmanager的容器中：
Ubuntu命令行：docker cp 本地文件路径 容器ID/容器NAME:容器内路径
docker cp/mnt/d/JetBrains/Work_Project/com.lx.flink-1.0-SNAPSHOT.jar599b7611e14a:/opt/flink进入jobmanager的容器中：
599b7……：是我的jobmanager的容器ID
通过命令ll，可以看见已经出现了
打开新的ubuntu，通过netcat输入数据：
继续执行命令：
bin/flink run：执行
-c com.lx.WordCount.StreamWordCount2：指定执行类com.lx.WordCount.StreamWordCount2
-p 2：并行度为2
com.lx.flink-1.0-SNAPSHOT.jar：需要运行的jar包
可以看到jar被执行成功，正在运行，生成了JOBID：
这个JOBID和WEBUI上的JOBID是一样的：
现在可以传输数据了：
传输的数据可以在taskmanager的stdout上查看，但是因为我这是Docker创建的容器，是无法查看stdout的，但是我可以通过dockerdesktop上的taskmanager的log查看：
可以看到数据传输是成功的！！
上一篇：Shader基础