Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4624#discussion_r142933355
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/batch/sql/CorrelateTest.scala
---
@@ -61,7 +62,8 @@ class CorrelateTest extends TableTestBase {
"DataSetCorrelate",
batchTableNode(0),
term("invocation", "func1($cor0.c, '$')"),
- term("function", func1.getClass.getCanonicalName),
+ term("correlate", s"table(func1($$cor0.c,'$$'))"),
--- End diff --
change to `term("correlate", s"table(func1($$cor0.c, '$$'))"),` for
consistency
---
