我试图运行这个示例,其中一些数据流正在被合并。为此,我使用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>
但是,有些类没有被识别(见图)。
1条答案
按热度按时间6yoyoihd1#
您链接到的示例是为Flink0.9编写的,您正在为Flink1.0添加依赖项。datastreamapi在这些版本之间进行了大量的重新工作。您应该使用flink0.9.x的依赖项,或者尝试更新的示例。例如,您可以从Flinkv1.0文档中尝试wikipediaanalysis示例。