开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink中有print在哪里看 word count的计算结果?

lQLPJw84H4UN7GLNChDNFACw0fhT44uaVI4EMAZKHgB1AA_5120_2576.png 有print在哪里看 word count的计算结果?

展开
收起
圆葱猪肉包 2023-04-19 16:44:41 642 0
3 条回答
写回答
取消 提交回答
  • 公众号:网络技术联盟站,InfoQ签约作者,阿里云社区签约作者,华为云 云享专家,BOSS直聘 创作王者,腾讯课堂创作领航员,博客+论坛:https://www.wljslmz.cn,工程师导航:https://www.wljslmz.com

    在阿里云实时计算 Flink版中,可以通过打印输出方式查看 WordCount 作业的计算结果。具体来说,可以在代码中使用print()方法打印结果到控制台上。例如:

    DataStream<Tuple2<String, Integer>> counts = words
        .flatMap(new FlatMapFunction<String, Tuple2<String, Integer>>() {
            @Override
            public void flatMap(String value, Collector<Tuple2<String, Integer>> out) {
                for (String word : value.split("\\s")) {
                    out.collect(new Tuple2<>(word, 1));
                }
            }
        })
        .keyBy(0)
        .sum(1);
    
    counts.print();
    

    在这段代码中,通过调用counts.print()方法,将计算结果输出到控制台上。您可以在 Flink 集群的作业管理界面上查看作业的输出日志,包括每个 TaskManager 的日志,以及整个作业的日志。另外,您也可以在本地调试时,在 IDE 的控制台上查看打印输出的计算结果。

    2023-04-30 22:55:06
    赞同 展开评论 打赏
  • taskmanager. 的 .out 里面,此回答整理自钉群“【③群】Apache Flink China社区”

    2023-04-19 22:36:05
    赞同 展开评论 打赏
  • 如果你是本地提交的,那可以在控制台看,如果你是提交到集群上运行的,可以在taskmanager的log查看,里面可以看到输出的内容

    2023-04-19 18:01:34
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

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