[flink] 03/04: [FLINK-17258][sql][test] Fix AggregateITCase.testPruneUselessAggCall missing sorted

[pn...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 05aa2d26d2dce3e6090ca59443f969afd28625cc
Author: Piotr Nowojski <pi...@gmail.com>
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