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