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]