2016-05-20 5 views
0

私はこれを実行しようとしています exampleいくつかのDataStreamがマージされています。私はこのためにEclipseを使用しており、指定されたMaven依存関係を追加しました。here私の依存関係は次のとおりです:EclipseでApache Flinkの例をコンパイルする

<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> 

しかし、いくつかのクラスは認識されません(画像参照)。

Classes not recognized by my compilter

答えて

2

あなたにリンクしている例がFLINK 0.9のために書かれている、あなたはFLINK 1.0の依存関係を追加しています。 DataStream APIは、これらのバージョン間で頻繁に再処理されています。 Flink 0.9.xに依存関係を使うか、もっと最近の例を試してみてください。たとえば、WikipediaAnalysis example from the Flink v1.0 documentationを試すことができます。

関連する問題