Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4625#discussion_r137010384
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamWindowJoinRule.scala
---
@@ -55,8 +55,10 @@ class DataStreamWindowJoinRule
if (windowBounds.isDefined) {
if (windowBounds.get.isEventTime) {
- // we cannot handle event-time window joins yet
- false
+ val procTimeAttrInOutput = join.getRowType.getFieldList.asScala
+ .exists(f => FlinkTypeFactory.isProctimeIndicatorType(f.getType))
+
+ !remainingPredsAccessTime && !procTimeAttrInOutput
--- End diff --
change to `!remainingPredsAccessTime`. It is OK to keep processing time
attributes in the join output.
---
