隨着當地弗林克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