[flink] 02/02: [hotfix][table] Printing column names in a deterministic order

[jark]

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

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

commit 270e6fc2094e2c879d32cacb3e096bf0eda53148
Author: Jark Wu <j...@apache.org>
AuthorDate: Sat Mar 11 23:02:30 2023 +0800

    [hotfix][table] Printing column names in a deterministic order
    
    This fixes unstable case of 
SqlDdlToOperationConverterTest#testCreateTableLikeInvalidPartition
---
 .../apache/flink/table/planner/operations/SqlCreateTableConverter.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/SqlCreateTableConverter.java
 
b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/SqlCreateTableConverter.java
index 4bba017db5e..294ab1c2386 100644
--- 
a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/SqlCreateTableConverter.java
+++ 
b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/SqlCreateTableConverter.java
@@ -45,6 +45,7 @@ import org.apache.calcite.util.NlsString;
 
 import java.util.Collections;
 import java.util.HashMap;
+import java.util.LinkedHashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.Optional;
@@ -210,7 +211,7 @@ class SqlCreateTableConverter {
         Set<String> columnNames =
                 mergedSchema.getColumns().stream()
                         .map(Schema.UnresolvedColumn::getName)
-                        .collect(Collectors.toSet());
+                        .collect(Collectors.toCollection(LinkedHashSet::new));
         for (String partitionKey : partitionKeys) {
             if (!columnNames.contains(partitionKey)) {
                 throw new ValidationException(