0

いくつかの DataStreams がマージされているこの 例を実行しようとしています。これには Eclipse を使用しており、ここで指定されているように Maven の依存関係を追加しました。ここに私の依存関係があります:

<dependencies>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-java</artifactId>
        <version>1.0.3</version>
    </dependency>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-streaming-java_2.10</artifactId>
        <version>1.0.3</version>
    </dependency>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-clients_2.10</artifactId>
        <version>1.0.3</version>
    </dependency>
    <!-- http://mvnrepository.com/artifact/org.apache.commons/commons-collections4 -->
    <dependency>
        <groupId>org.apache.commons</groupId>
        <artifactId>commons-collections4</artifactId>
        <version>4.0</version>
    </dependency>
</dependencies>

ただし、一部のクラスは認識されていません (図を参照)。

コンパイラで認識されないクラス

4

1 に答える 1

2

リンク先の例は Flink 0.9 用に書かれており、Flink 1.0 の依存関係を追加しています。DataStream API は、これらのバージョン間で大幅に作り直されました。Flink 0.9.x の依存関係を使用するか、より最近の例を試す必要があります。たとえば、Flink v1.0 ドキュメント から WikipediaAnalysis の例を試すことができます。

于 2016-05-20T17:27:16.303 に答える