connectedStream 不输出数据

来源:11-19 完成两个流关联的数据清洗功能

chris__

2019-09-18

按照课程继续开发最后一个需求时,按照之前的方法不输出数据,
图片描述
截至keyBy都可以输出,添加上window后就没有输出,可能是触发不了窗口,但是想不通问题出在哪,图片描述
这里是connectStream 返回的数据

写回答

1回答

Michael_PK

2019-09-19

代码这么看,真没看出哪有问题。两个思路:1),对比下git的代码,2)测试数据的时间也要关注下,也就是你说的可能没触发

0
1
chris__
我把每一段都测试了,代码肯定没有错误,就是无法一起跑,把connect去掉,logdata返回值中手动添加userId 跑是没问题的,加上connect代码不加window也是没问题的,只要加上logData.connect(mysql) 后再加上window 不管是什么window都输出不了结果,我看了eventTime和waterMark 至少看起来也是没问题的,希望pk哥能尝试着接着课程里的代码 实现一下最后的功能看看会不会出现这种情况。。
2019-09-19
共1条回复

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

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

969 学习 · 296 问题

查看课程