From 27df84cca0ff6e9040945e27418beb6b11771949 Mon Sep 17 00:00:00 2001 From: zhouxin <1027301599@qq.com> Date: Tue, 22 Aug 2023 10:34:19 +0800 Subject: [PATCH] [Hotfix][connector-v2][clickhouse] fix CI error --- .../client/executor/JdbcBatchStatementExecutorBuilder.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/executor/JdbcBatchStatementExecutorBuilder.java b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/executor/JdbcBatchStatementExecutorBuilder.java index a1c6e3733e3..5ca2e57b10b 100644 --- a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/executor/JdbcBatchStatementExecutorBuilder.java +++ b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/executor/JdbcBatchStatementExecutorBuilder.java @@ -57,7 +57,9 @@ private boolean supportReplacingMergeTreeTableUpsert() { private String[] getDefaultProjectionFields() { List fieldNames = Arrays.asList(rowType.getFieldNames()); - return fieldNames.stream().filter(clickhouseTableSchema::containsKey).toArray(String[]::new); + return fieldNames.stream() + .filter(clickhouseTableSchema::containsKey) + .toArray(String[]::new); } public JdbcBatchStatementExecutor build() {