dianfu commented on code in PR #19765:
URL: https://github.com/apache/flink/pull/19765#discussion_r876810959
##########
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/timer/TimerRegistration.java:
##########
@@ -105,6 +111,17 @@ private void setTimer(TimerOperandType operandType, long
timestamp, Row key, Obj
}
}
+ /**
+ * Returns if there's any event-time timer in the queue, that should be
triggered because
+ * watermark advance.
+ */
+ public boolean isTimerQueueClean(long watermark) throws Exception {
Review Comment:
```suggestion
public boolean hasEventTimeTimerBeforeTimestamp(long watermark) throws
Exception {
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
