If we add an additional flag, we just duplicate the same logic, since we would 
still need to handle this `Optional` field:
```
if (isRowtimeMode) {
  throw new ValidationException(
     s"Currently only proctime temporal joins are supported in 
[${textualRepresentation}]")
}
checkState(!rightTimeAttribute.isDefined);
```

Alternative solution (IMO not worth the effort here) would be to split this 
class and have one for processing time and one for rowtime. Then we could skip 
this check altogether.

[ Full content available at: https://github.com/apache/flink/pull/6299 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to