Github user lincoln-lil commented on a diff in the pull request:
https://github.com/apache/flink/pull/4858#discussion_r146504940
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/operators.scala
---
@@ -486,11 +486,6 @@ case class Join(
s"Invalid join condition: $expression. At least one equi-join
predicate is " +
s"required.")
}
- if (joinType != JoinType.INNER && (nonEquiJoinPredicateFound ||
localPredicateFound)) {
--- End diff --
Local variable `nonEquiJoinPredicateFound` and `localPredicateFound` can be
removed here, and `checkIfFilterCondition` method is no longer needed
---
