Github user fhueske commented on a diff in the pull request:

    https://github.com/apache/flink/pull/4858#discussion_r146591835
  
    --- 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 --
    
    Good point. Will remove that. Thanks @lincoln-lil!


---

Reply via email to