Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4624#discussion_r142933262
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/batch/sql/CorrelateTest.scala
---
@@ -41,7 +41,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))"),
+ term("select", "a,b,c,f0"),
--- End diff --
please change to `term("select", "a", "b", "c", "f0"),` (i.e., use separate
strings for the field names) for consistency
---
