connectedStream 不输出数据

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

chris__

2019-09-18

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

写回答

1回答

Michael_PK

2019-09-19

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

chris__

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

2019-09-19

共1条回复

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

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

969 学习 · 296 问题

查看课程

相似问题

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

回答 1

watermark——late element疑问

回答 1

MapPartition也可以连接数据库，那是否可以直接用MapPartition将数据输出，不用自定义sinkFunction？

回答 1

大数据面试经验

回答 1

timeWindow 使用问题

回答 1

打开慕课网App查看更多内容