在 Eclipse 中编译 Apache Flink 示例

Question

我正在尝试运行这个 example where some DataStreams are being merged. I am using Eclipse for this and I added the Maven dependencies as specified here。这是我的依赖项：

<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 的依赖项或尝试更新的示例。例如，您可以尝试 WikipediaAnalysis example from the Flink v1.0 documentation.

在 Eclipse 中编译 Apache Flink 示例

Compiling an Apache Flink Example in Eclipse

apache-flink

flink-streaming