Flink 0.10.1错误

Question

使用flink 0.10.1在本地，由于以下错误，我无法与作业管理器连接：

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>

用flink 0.9.1很好.我错过了什么？谢谢!

Answer 1

好的，问题是:在flink下载页面上有几个指向Flink项目的链接(二进制文件和源代码)，我已经下载了没有hadoop的普通链接，因为这是为了本地的测试目的，我不使用hadoop。但是我现在不需要它为什么需要我下载的scala的hadoop :Hadoop2.7.0和Scala2.10，而且它可以工作。

Answer 2

这听起来像是版本错过匹配，也就是说，在您的代码库中有旧的0.9.1二进制文件.尝试通过以下方式清理maven缓存

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

然后，重新构建您的项目：mvn -DskipTests clean package