发现一个问题大佬能帮忙解答一二？ 1. 数据中的补充表（补充流信息， 流信息的设备配置全集） 2.数据流 kafka原表 主要想实现的目标 发现一段时间内未发送消息的设备 主要实现流程 1. 2小时的滑动窗口来distinct所有的设备ID 2. 查询mysql的设备合集表 查询 ID not in (distinct id from 滑动窗口) 直接查询的时候是没有问题的 能达到批和流一起使用 但是结果插入数据库的时候变成了批 mysql中的结果不会变化 请问这种情况是什么机制 如果是批流一体情况下 回当做批处理那为啥select的时候能实现目标？