随着当地弗林克0.10.1我不能因以下错误jobmanager连接:误差弗林克0.10.1
Association with remote system [akka.tcp://[email protected]:49789] has failed, address is now gated for [5000] ms. Reason is: [scala.Option; local class incompatible: stream classdesc serialVersionUID = -2062608324514658839, local class serialVersionUID = -114498752079829388].
而且我的pom.xml:
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-java</artifactId>
<version>0.10.1</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-clients</artifactId>
<version>0.10.1</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-hadoop-compatibility</artifactId>
<version>0.10.1-hadoop1</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-jdbc</artifactId>
<version>0.10.1-hadoop1</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.6</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-ml</artifactId>
<version>0.10.1-hadoop1</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java</artifactId>
<version>0.10.1</version>
</dependency>
</dependencies>
随着弗林克0.9.1正常工作...我错过了什么?谢谢!
谢谢,但我做到了,错误仍然存在 – deimos1975
如何启动JobManager并提交程序?你确定你的Flink集群的二进制文件是0.10.1而不是0.9.1吗?我想你下载Flink二进制文件,对吧?还是你从源代码构建Flink? –
我启动本地服务器只Flik以 “启动local.bat” 我的提交程序:'\t \t最终执行环境ENV =执行环境 \t \t \t .createRemoteEnvironment(Messages.getString( “Job.host”)TRIM() , \t \t \t \t \t \t 6123 Messages.getString( “Job.JobJar”));' – deimos1975