Apache Flink CEP-Timout-Muster im Zeitfenster nicht definiert

Question

Ich verwende PatternTimeoutFunction, um die Ereignissequenz zu verwerfen, wenn sie außerhalb des definierten Zeitfensters liegt.

ich das Wasserzeichen setze als

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

folge Wenn Muster Timeout geschieht, timeoutTimestamp sollte

zum ersten Ereignisse Zeitstempeln + Wert des Zeitfensters gleich sein, aber Timeout auslöst, nachdem die nächsten Wasserzeichen zu empfangen. Wird die Zeitüberschreitung ausgelöst, nachdem das nächste Wasserzeichen empfangen wurde oder timeWindow abgelaufen ist?

Answer 1

Die Zeitüberschreitung wird durch den Empfang der Wasserzeichen ausgelöst, wenn Sie die Ereigniszeit verwenden. Weil Sie nur sicher sein können, alle Elemente bis zu einem bestimmten Punkt gesehen zu haben, wenn Sie das Wasserzeichen für diesen Zeitstempel erhalten.

Dies bedeutet, dass der Timeout-Zeitstempel abhängig vom Wert des nächsten Wasserzeichens größer als der erste Ereigniszeitstempel + die Fensterlänge sein kann. Daher ist der Timeout-Zeitstempel tatsächlich die Ereigniszeit, wenn Sie feststellen, dass Ihr Muster abgelaufen ist.