This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git
commit bb64296c7a28ac2e51a741082b0d9c6de037de69 Author: Piotr Nowojski <[email protected]> AuthorDate: Sat May 16 15:00:19 2020 +0200 [FLINK-17258][sql][test] Fix AggregateITCase.testPruneUselessAggCall missing sorted The result of this query doesn't guarantee any ordering. This brakes with enabled unaligned checkpoints. --- .../apache/flink/table/planner/runtime/stream/sql/AggregateITCase.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/AggregateITCase.scala b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/AggregateITCase.scala index 73b5801..1a9485d 100644 --- a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/AggregateITCase.scala +++ b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/AggregateITCase.scala @@ -1210,7 +1210,7 @@ class AggregateITCase( t1.toRetractStream[Row].addSink(sink).setParallelism(1) env.execute() val expected = List("1", "3") - assertEquals(expected, sink.getRetractResults) + assertEquals(expected.sorted, sink.getRetractResults.sorted) } @Test
