Apache Flink CEPタイムアウトパターンが時間ウィンドウで定義されていない

Question

私がPatternTimeoutFunctionを使用して、定義された時間ウィンドウから外れるとイベントシーケンスを破棄します。

パターンタイムアウトが発生すると

public Watermark checkAndGetNextWatermark(Event lastElement, long extractedTimestamp) { 
    return new Watermark(extractedTimestamp); 
} 

は、timeoutTimestamp次の透かしを受信した後、最初のイベントのタイムスタンプ+ timewindow

しかし、タイムアウトがトリガさの値に等しくなければならない次のように私は透かしを設定しています。次の透かしを受信した後、またはtimeWindow期限切れに基づいてタイムアウトが発生しましたか？

Answer 1

イベントタイムを使用すると、タイムアウトはウォーターマークの受信によってトリガーされます。このタイムスタンプのウォーターマークを受け取った場合、特定のポイントまですべての要素を見たことができるだけであるためです。

これは、タイムアウトタイムスタンプが、次のウォーターマークの値に応じて、最初のイベントタイムスタンプ+ウィンドウ長より長くなる可能性があることを意味します。したがって、タイムアウトタイムスタンプは実際には、あなたのパターンがタイムアウトしたことを認識したときのイベント時刻です。