1
異なる物理デバイスがイベントを送信しているユースケースを実装しようとしています。ネットワーク/電源の問題のために、フリンクソースでイベントを受信するのが遅くなる可能性があります。 Flinkジョブ内の演算子の1つにパターン演算子があります。また、パターンには時間が敏感であるため、イベントの時間特性を使用しています。しかし、特定のデバイスからのイベントに予期せぬ遅延があり、そのイベントが落ちる原因となる問題が発生します（静的な境界を定義して遅延を許容することはできません）。KeyedStream（Apache Flink）でキーごとにウォーターマークを生成することは可能ですか？
ソースデバイスIDをキーとするKeyedStreamを使用しているので、各CEP演算子インスタンス（キーごとに1つずつ）に、対応するストリームパーティションのイベント時刻に基づいて時間を進める方法があります。つまり、KeyedStreamのパーティションごとにウォーターマークを生成する方法はありますか？