> > CREATE TEMPORARY VIEW filteredResults AS > SELECT * from suspiciousOrders WHERE small_ts > large_ts;
Looks like after added the condition, the final expanded query should not match the condition[1] of an interval join that leads to the planner recognize it as an interval join. It’s not a bug, interval join is a special case of regular join, thus the result would be still correct. [1] https://nightlies.apache.org/flink/flink-docs-release-1.14/zh/docs/dev/datastream/operators/joining/#interval-join