0

ローカルで 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 を使用すると問題なく動作します...何が欠けていますか? ありがとうございました！

4

2 に答える 2

3

バージョンミスマッチのようです。つまり、コードベースに古い 0.9.1 バイナリがあるようです...次の方法で Maven キャッシュを消去してください。

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

その後、プロジェクトを再構築します。mvn -DskipTests clean package

于 2015-12-31T13:51:30.367 に答える