DockerDesktop搭建Flink集群：命令行提交jar包_旅游资讯

创始人

2025-05-30 20:25:31

一般提交任务都是在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查看：

可以看到数据传输是成功的！！