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

Question

在11-11 节中，添加了WindowFunction 的方法以及实现后，调用resultData.print().setParallelism(1) 没有效果。控制台一直无新数据显示，如下：

停留在这里，之前11-10都可以正常输出。使用老师代码替换，也是一样。
注： 在apply 方法中添加 println 方法后，发现没有打印。

希望PK老师帮忙解惑，多谢！

Answer 1

Michael_PK 2020-02-11 13:44:26

kafka有数据不

• 提问者 慕虎3523500 #1

  老师是这样的，kafka 生产数据一切正常，且服务器端也可以消费。主要是LogAnalysis文件flink 接收消费的时候出的问题。目前测试的结果是：没有窗口函数的情况下，可以正常输出数据，类似如下：
  (1581400175000,v2.go2yd.com,6587)
  (1581400177000,v3.go2yd.com,3955)
  (1581400181000,vmi.go2yd.com,8136)
  (1581400183000,v2.go2yd.com,7906)
  
  。添加了窗口逻辑代码后，就如问题的截图，一直没有输出。

• Michael_PK 回复 提问者 慕虎3523500 #2

  那你这样，一步步来排查，先不用窗口，看看数据是否能到，如果可以那基本就是窗口的条件没被触发了

• 提问者 慕虎3523500 回复 Michael_PK #3

  不用窗口数据可以获取到，但是加上窗口，就没有数据了，应该是没有触发，可是不知道哪里的问题？怎么排查呢？我在apply 的实现方法里加入了println 语句，没有被调用。

点开查看后面11条评论