apache-flink - 在 Eclipse 中编译 Apache Flink 示例

Question

我正在尝试运行此 示例，其中一些 DataStream 正在合并。我为此使用 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>

但是，有些类没有被识别（见图）。

Answer 1

您链接到的示例是为 Flink 0.9 编写的，并且您正在为 Flink 1.0 添加依赖项。DataStream API 在这些版本之间进行了大量重新设计。您应该使用 Flink 0.9.x 的依赖项或尝试更新的示例。例如，您可以尝试Flink v1.0 文档中的 WikipediaAnalysis 示例。