Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4842#discussion_r145345140
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/CorrelateITCase.scala
---
@@ -82,6 +82,45 @@ class CorrelateITCase extends
StreamingMultipleProgramsTestBase {
assertEquals(expected.sorted, StreamITCase.testResults.sorted)
}
+ /**
+ * Due to CALCITE-2004, common join predicates are temporarily
forbidden.
+ */
+ @Test (expected = classOf[ValidationException])
+ def testLeftOuterJoinWithPredicates(): Unit = {
--- End diff --
I see, but let's rather add a JIRA issue for FLINK and link to that one
(which links to the Calcite JIRA and the discussion on the Calcite dev list).
---
