在Eclipse中编译apacheflink示例


0

我正在试着运行这个

<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 答案


0

您 chaining接到的示例是为Flink 0.9编写的,您正在为Flink 1.0添加依赖项。datastreamapi在这些版本之间进行了大量的重新 job 。您应该对flink0.9.x使用依赖关系,或者尝试一个更新的示例。例如,您可以尝试FlinkV1.0文档中的WikipediaAnalysis示例。


我来回答

写文章

提问题

面试题