flink示例

lmvvr0a8  于 2021-06-25  发布在  Flink
关注(0)|答案(1)|浏览(439)

我试图运行这个示例,其中一些数据流正在被合并。为此,我使用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>

但是,有些类没有被识别(见图)。

6yoyoihd

6yoyoihd1#

您链接到的示例是为Flink0.9编写的,您正在为Flink1.0添加依赖项。datastreamapi在这些版本之间进行了大量的重新工作。您应该使用flink0.9.x的依赖项,或者尝试更新的示例。例如,您可以从Flinkv1.0文档中尝试wikipediaanalysis示例。

相关问题