http://git-wip-us.apache.org/repos/asf/flink/blob/2d33c0be/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/WindowAggregateTest.scala ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/WindowAggregateTest.scala b/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/WindowAggregateTest.scala index 9d16536..4f46a73 100644 --- a/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/WindowAggregateTest.scala +++ b/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/WindowAggregateTest.scala @@ -199,6 +199,37 @@ class WindowAggregateTest extends TableTestBase { util.verifySql(sqlQuery, expected) } + @Test + def testWindowEndOnly(): Unit = { + val util = batchTestUtil() + util.addTable[(Int, Long, String, Timestamp)]("T", 'a, 'b, 'c, 'ts) + + val sqlQuery = + "SELECT " + + " TUMBLE_END(ts, INTERVAL '4' MINUTE)" + + "FROM T " + + "GROUP BY TUMBLE(ts, INTERVAL '4' MINUTE), c" + + val expected = + unaryNode( + "DataSetCalc", + unaryNode( + "DataSetWindowAggregate", + unaryNode( + "DataSetCalc", + batchTableNode(0), + term("select", "ts, c") + ), + term("groupBy", "c"), + term("window", EventTimeTumblingGroupWindow('w$, 'ts, 240000.millis)), + term("select", "c, start('w$) AS w$start, end('w$) AS w$end") + ), + term("select", "CAST(w$end) AS w$end") + ) + + util.verifySql(sqlQuery, expected) + } + @Test(expected = classOf[TableException]) def testTumbleWindowNoOffset(): Unit = { val util = batchTestUtil()
http://git-wip-us.apache.org/repos/asf/flink/blob/2d33c0be/tools/maven/suppressions.xml ---------------------------------------------------------------------- diff --git a/tools/maven/suppressions.xml b/tools/maven/suppressions.xml index 2c29054..8a80341 100644 --- a/tools/maven/suppressions.xml +++ b/tools/maven/suppressions.xml @@ -25,4 +25,6 @@ under the License. <suppressions> <suppress files="org[\\/]apache[\\/]flink[\\/]api[\\/]io[\\/]avro[\\/]example[\\/]User.java" checks="[a-zA-Z0-9]*"/> <suppress files="org[\\/]apache[\\/]flink[\\/]api[\\/]io[\\/]avro[\\/]generated[\\/].*.java" checks="[a-zA-Z0-9]*"/> + <!-- Sometimes we have to temporarily fix very long, different formatted Calcite files. --> + <suppress files="org[\\/]apache[\\/]calcite.*" checks="[a-zA-Z0-9]*"/> </suppressions>
