开发者社区> 问答> 正文

flink基于集合的Source代码运行的时候报错

        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        env.setRuntimeMode(RuntimeExecutionMode.AUTOMATIC);

        //2.source
        // * 1.env.fromElements(可变参数);
        DataStream<String> ds1 = env.fromElements("hadoop", "spark", "flink");
        // * 2.env.fromColletion(各种集合);
        DataStream<String> ds2 = env.fromCollection(Arrays.asList("hadoop", "spark", "flink"));
        // * 3.env.generateSequence(开始,结束);
        DataStream<Long> ds3 = env.generateSequence(1, 10);
        //* 4.env.fromSequence(开始,结束);
        DataStream<Long> ds4 = env.fromSequence(1, 10);

        //3.Transformation

        //4.sink
        ds1.print();
        ds2.print();
        ds3.print();
        ds4.print();

        //5.execute
        env.execute();

image.png

刚开始学习,照着网上的代码运行,现在报错,请大神协助

展开
收起
ufoxiaoyuer 2023-06-13 17:24:27 57 0
1 条回答
写回答
取消 提交回答
  • 根据您提供的代码和错误信息,可以看出是缺少 Flink 的依赖库导致的。

    您可以尝试添加以下依赖库到您的项目中:

    <dependencies>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-core</artifactId>
            <version>${flink.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-streaming-java_2.12</artifactId>
            <version>${flink.version}</version>
        </dependency>
    </dependencies>
    

    其中 ${flink.version} 可以替换为您使用的 Flink 版本。

    如果您已经添加了这些依赖库,那么请检查您的依赖库版本是否正确,或者您的依赖库是否与您的 Flink 版本不兼容。建议使用与您的 Flink 版本相对应的依赖库。

    2023-06-13 18:29:52
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载