Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5619#discussion_r188931486
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/sql/AggregateITCase.scala
---
@@ -367,6 +367,36 @@ class AggregateITCase(
TestBaseUtils.compareResultAsText(result.asJava, expected)
}
+ @Test
+ def testUnnestMultisetFromTumbleWindowAggregateCollectResult(): Unit = {
+ val env = ExecutionEnvironment.getExecutionEnvironment
+ val tEnv = TableEnvironment.getTableEnvironment(env, config)
+
+ val sqlQuery =
+ "SELECT b, COLLECT(b) as `set`" +
+ "FROM T " +
+ "GROUP BY b, TUMBLE(ts, INTERVAL '3' SECOND)"
+
+ val ds = CollectionDataSets.get3TupleDataSet(env)
+ // create timestamps
+ .map(x => (x._1, x._2, x._3, toTimestamp(x._1 * 1000)))
+ tEnv.registerDataSet("T", ds, 'a, 'b, 'c, 'ts)
+
+ val view1 = tEnv.sqlQuery(sqlQuery)
+ tEnv.registerTable("v1", view1)
+
+ val sqlQuery1 = "SELECT b, s FROM v1 t1, unnest(t1.`set`) AS A(s)
where b < 3"
--- End diff --
Remove the renaming of `v1` to `t1`.
---
