Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3484#discussion_r106684413
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java
---
@@ -567,6 +600,17 @@ protected boolean isLate(W window) {
}
/**
+ * Decide if a record is currently late, based on current watermark and
allowed lateness.
+ *
+ * @param element The element to check
+ * @return The element for which should be considered when sideoutputs
+ */
+ protected boolean isLate(StreamRecord<IN> element){
--- End diff --
That is what I remember as well.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
