2015-12-30 96 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