admin管理员组

文章数量:1648562

我集群是Standalone

文件和jar我三台机器都有了

集群也启动了

 

 

 

我首先在win本地运行了一下成功了

然后我在网页上执行的

结果失败了我查看了taskmanager日志jobmanager日志

Taskmanager说是:JobManager负责e6b20ded57f2f6ef23838a990b3e567f丢失了领导权。

Jobmanager说是:id2823081f352b915dcebbda277d285ce1TaskManager心跳超时。

 

最后提交到Flink集群上去的时候报错,说是 “无法从JAR文件构建程序”

 

查看log 说是 “不存在JAR文件”

 

解决方法 :

1.重启集群

2.看下你得命令是否写错

格式如下

 bin/flink run -c com.imau.edu.flink.DataSet_WordCountLoad /opt/module/flink-1.7.0/datas/Flink_Demo-1.0-SNAPSHOT.jar --input /opt/module/flink-1.7.0/datas/hello.txt --output /opt/module/flink-1.7.0/datas/output_2019_11_23.csv

 

bin/flink run -c 类名 jar包地址 -- input文件地址 --output输出地址

 

本文标签: 领导权报错集群说是文件