在Eclipse中編譯Apache Flink示例

Question

我試圖運行此 example其中一些DataStreams被合併。我爲此使用了Eclipse，並且我添加了指定here的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> 

然而，有些類不被認可（見圖片）。

Answer 1

要鏈接的例子爲0.9弗林克書面和您要添加的依賴關係弗林克1.0。 DataStream API在這些版本之間大量重新工作。您應該使用Flink 0.9.x的依賴關係或嘗試更新的示例。例如，你可以試用WikipediaAnalysis example from the Flink v1.0 documentation。