Skip to content

Commit 051d19c

Browse files
authored
[Fix][Connector-V2] Fix the problem that missing options configuration when building ClickHouse Nodes (#9277)
1 parent 0b1122c commit 051d19c

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSinkFactory.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,7 @@
4242
import java.util.Map;
4343
import java.util.stream.Collectors;
4444

45+
import static org.apache.seatunnel.connectors.seatunnel.clickhouse.config.ClickhouseBaseOptions.CLICKHOUSE_CONFIG;
4546
import static org.apache.seatunnel.connectors.seatunnel.clickhouse.config.ClickhouseBaseOptions.DATABASE;
4647
import static org.apache.seatunnel.connectors.seatunnel.clickhouse.config.ClickhouseBaseOptions.HOST;
4748
import static org.apache.seatunnel.connectors.seatunnel.clickhouse.config.ClickhouseBaseOptions.PASSWORD;
@@ -95,7 +96,7 @@ public TableSink createSink(TableSinkFactoryContext context) {
9596
readonlyConfig.get(SERVER_TIME_ZONE),
9697
readonlyConfig.get(USERNAME),
9798
readonlyConfig.get(PASSWORD),
98-
null);
99+
readonlyConfig.get(CLICKHOUSE_CONFIG));
99100

100101
ClickhouseProxy proxy = new ClickhouseProxy(nodes.get(0));
101102
Map<String, String> tableSchema = proxy.getClickhouseTableSchema(readonlyConfig.get(TABLE));

seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/util/ClickhouseUtil.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ public static List<ClickHouseNode> createNodes(ReadonlyConfig config) {
4141
config.get(ClickhouseBaseOptions.SERVER_TIME_ZONE),
4242
config.get(ClickhouseBaseOptions.USERNAME),
4343
config.get(ClickhouseBaseOptions.PASSWORD),
44-
null);
44+
config.get(ClickhouseBaseOptions.CLICKHOUSE_CONFIG));
4545
}
4646

4747
public static List<ClickHouseNode> createNodes(

0 commit comments

Comments
 (0)