我正在努力实现一个用例，其中不同的物理设备正在发送事件，并且由于网络/电源问题，在flink源处接收事件可能会有延迟 . flink作业中的一个操作符是Pattern操作符，并且某些模式对时间敏感，因此我使用事件时间特性 . 但问题出现在来自特定设备的事件中存在不可预测的延迟时，这会导致这些事件被丢弃（因为我无法真正定义允许延迟的静态边界） .
由于我使用KeyedStream，键入源设备ID，有没有办法允许每个CEP操作员实例（每个键一个）根据相应流分区中的事件时间来提前计时 . 或者换句话说，有没有办法在KeyedStream中为每个分区生成水印？
1 回答
Flink目前不支持每个关键水印 . 水印是全球性的 .