Flink 0.10.1 错误

Question

在本地使用 flink 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>

使用 flink 0.9.1 工作正常......我缺少什么？谢谢！

Answer 1

这听起来像是版本不匹配，也就是说，你的代码库中有旧的 0.9.1 二进制文件...尝试通过

清理你的 Maven 缓存

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

之后，重建您的项目：mvn -DskipTests clean package

Answer 2

好的，问题如下：在 flink 下载页面上有几个指向 Flink 项目的链接（二进制文件和源代码）我已经下载了没有 hadoop 的普通版本，因为这是为了在我的本地进行测试，我不使用 hadoop。但我现在不明白为什么它不需要我下载的带有 scala 的 hadoop： Hadoop 2.7.0 和 scala 2.10 并且可以正常工作。

Flink 0.10.1 错误

Error with Flink 0.10.1

maven

apache-flink

flink-streaming

flinkml