[Hotfix][connector-v2][clickhouse] Fixed an out-of-order BUG with out…

…put data fields of clickhouse-sink (apache#5346)
nexr · Dec 14, 2023 · c6aa4a6 · c6aa4a6
1 parent 3be869e
commit c6aa4a6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...nnectors/seatunnel/clickhouse/sink/client/executor/JdbcBatchStatementExecutorBuilder.java b/...nnectors/seatunnel/clickhouse/sink/client/executor/JdbcBatchStatementExecutorBuilder.java
@@ -57,8 +57,8 @@ private boolean supportReplacingMergeTreeTableUpsert() {
 
     private String[] getDefaultProjectionFields() {
         List<String> fieldNames = Arrays.asList(rowType.getFieldNames());
-        return clickhouseTableSchema.keySet().stream()
-                .filter(fieldNames::contains)
+        return fieldNames.stream()
+                .filter(clickhouseTableSchema::containsKey)
                 .toArray(String[]::new);
     }