我有一个 Flink 程序，它接收两个流，即数据/传感器读数流和警报规则流。我正在广播规则流并将其连接到数据流以生成动态警报。ProcessingTime 一切正常，但 EventTime 没有任何效果。我已经为我的数据流分配了时间戳和水印，并按原样传递了规则流（因为规则流只有在看到新的附加规则/更新时才会有记录）。但不会生成警报。
当两个流，即一个带有时间戳和水印的流和一个只有规则（广播）的流被连接并根据规则动态处理时，如何使用“EventTime”来生成警报。
我是否一定需要为我的规则流分配时间戳和水印？
因为我的规则流只有在有任何添加/修改时才会有记录。是否有任何解决方法或技巧可以避免/克服这种情况？
任何帮助/建议将不胜感激。
——我试过了！我尝试使用一个流，即数据流，通过使用硬编码窗口规则生成警报。它工作正常。但是当我将它与规则流连接时，它无法生成任何警报/输出。
使用“ProcessingTime”一切正常，但使用“EventTime”则不然。
——我所期待的！我希望我的程序能够工作，当我将连续数据流与非连续规则流连接时，使用“EventTime”生成动态警报。