Details
-
Improvement
-
Status: Closed
-
Minor
-
Resolution: Duplicate
-
None
-
None
-
None
Description
currently the test case in flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/table/JoinITCase.scala
will throw a ValidationException indicating: “Invalid non-join predicate 'b < 3. For non-join predicates use Table#where.”
JoinITCase.scala
@Test(expected = classOf[ValidationException]) def testNoJoinCondition(): Unit = { … val ds1 = CollectionDataSets.get3TupleDataSet(env).toTable(tEnv, 'a, 'b, 'c) val ds2 = CollectionDataSets.get5TupleDataSet(env).toTable(tEnv, 'd, 'e, 'f, 'g, 'h) val joinT = ds2.leftOuterJoin(ds1, 'b === 'd && 'b < 3).select('c, 'g) }
This jira aims to supported this kind of local predicates in outer joins.
More detailed description: http://goo.gl/gK6vP3
Attachments
Attachments
Issue Links
- duplicates
-
FLINK-5498 Add support for left/right outer joins with non-equality predicates (and 1+ equality predicates)
- Closed