添加窗口后,消费端无法输出数据

来源:11-11 WindowFunction业务逻辑的实现

慕虎3523500

2020-02-11

在11-11 节中,添加了WindowFunction 的方法以及实现后,调用resultData.print().setParallelism(1) 没有效果。控制台一直无新数据显示,如下:
图片描述
停留在这里,之前11-10都可以正常输出。使用老师代码替换,也是一样。
注: 在apply 方法中添加 println 方法后,发现没有打印。

希望PK老师帮忙解惑,多谢!

写回答

1回答

Michael_PK

2020-02-11

kafka有数据不

0
14
慕虎3523500
回复
Michael_PK
好的,多谢老师解惑,我先按照这个思路去排查一下。有问题再请教老师。
2020-02-13
共14条回复

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势,多语言系统化讲解,极速入门Flink

969 学习 · 296 问题

查看课程