是否有可能在KeyedStream (Apache )中生成每个密钥的水印？

Question

我正在实现一个用例，其中不同的物理设备正在发送事件，由于网络/电源问题，在flink源接收事件时可能会出现延迟。flink作业中的一个操作符是模式操作符，有一些模式是时间敏感的，所以我使用事件时间特性。但是，当来自特定设备的事件出现不可预测的延迟时，问题就出现了，这会导致那些事件被删除(因为我不能真正定义允许延迟的静态绑定)。

由于我使用的是在源设备ID上键控的KeyedStream，是否有一种方法允许每个CEP操作符实例(每个键一个)根据相应流分区中的事件时间来推进其时间。换句话说，是否有一种方法可以在KeyedStream中生成每个分区的水印？

Answer 1

Flink目前不支持每个关键水印。水印是全局的。