Ошибка с Флинка 0.10.1

Question

С Флинка 0.10.1 в местный я не могу соединиться с JobManager из-за следующей ошибки:

Association with remote system [akka.tcp://flink@127.0.0.1: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 отлично работает ... Что мне не хватает? Спасибо!

Answer 1

Хорошо, проблема заключалась в следующем: на FLiNK страницы загрузок есть несколько ссылок на проект FLiNK (двоичные файлы и источник) Я загрузил нормальные без Hadoop, потому что для целей тестирования в моем местной и я не Использовать hadoop. Но я не думаю, почему его нужно использовать с scala Скачано: Hadoop 2.7.0 с scala 2.10 и он работает.

Answer 2

Это звучит как промах матч версии, то есть, что у вас есть старые 0.9.1 двоичных файлов в программном коде ... Попробуйте очистить кэш Maven через

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

После этого восстановить свой проект: mvn -DskipTests clean package