Update FlinkPipelineComposerLenientITCase.java

apache · Oct 25, 2024 · 80853f5 · 80853f5
1 parent 20c327b
commit 80853f5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposerLenientITCase.java b/...src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposerLenientITCase.java
@@ -211,7 +211,7 @@ void testSingleSplitSingleTableWithDefaultValue(ValuesDataSink.SinkApi sinkApi)
         // Check result in ValuesDatabase
         List<String> results = ValuesDatabase.getResults(TABLE_1);
         assertThat(results)
-                .containsExactly(
+                .containsExactlyInAnyOrder(
                         "default_namespace.default_schema.table1:col1=2;col2=;col3=;newCol2=;newCol3=x;colWithDefault=;newColWithDefault=",
                         "default_namespace.default_schema.table1:col1=3;col2=3;col3=;newCol2=;newCol3=;colWithDefault=;newColWithDefault=");