diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/source/DorisSourceITCase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/source/DorisSourceITCase.java index 894237fe6..a13e96f7f 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/source/DorisSourceITCase.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/source/DorisSourceITCase.java @@ -306,7 +306,7 @@ public void testTableSourceFilterWithUnionAll() throws Exception { actual.add(iterator.next().toString()); } } - String[] expected = new String[] {"+I[flink, 10]", "+I[doris, 18]"}; + String[] expected = new String[] {"+I[doris, 18]", "+I[flink, 10]"}; Assert.assertArrayEquals(expected, actual.toArray()); }