2015-12-30 64 views
0

随着当地弗林克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正常工作...我错过了什么?谢谢!

回答

1

好了,问题是以下几点: 在弗林克下载页面有几个链接弗林克项目(二进制和源代码) 我已经下载了正常的人没有Hadoop的,因为是为了测试在我的地方,我不要不使用hadoop。 但我现在不要为什么它需要与我已下载的Scala的hadoop的: Hadoop 2.7.0与Scala 2.10,它的工作原理。

3

这听起来像一个版本小姐的比赛,也就是说,你已经在你的代码基础的老0.9.1二进制文件...尝试通过

cd ~/.m2/repositories/org/apache/flink 
rm -rf * 

清理你的Maven缓存之后,重新构建项目:mvn -DskipTests clean package

+0

谢谢,但我做到了,错误仍然存​​在 – deimos1975

+0

如何启动JobManager并提交程序?你确定你的Flink集群的二进制文件是0.10.1而不是0.9.1吗?我想你下载Flink二进制文件,对吧?还是你从源代码构建Flink? –

+0

我启动本地服务器只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