Skip to content

Commit 5c14379

Browse files
committed
[hotfix] Create the connection using connectionProperties #118
1 parent a71a0ed commit 5c14379

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

flink-connector-clickhouse/src/main/java/org/apache/flink/connector/clickhouse/internal/AbstractClickHouseOutputFormat.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -189,7 +189,8 @@ public AbstractClickHouseOutputFormat build() {
189189

190190
ClickHouseConnectionProvider connectionProvider = null;
191191
try {
192-
connectionProvider = new ClickHouseConnectionProvider(options);
192+
connectionProvider =
193+
new ClickHouseConnectionProvider(options, connectionProperties);
193194
DistributedEngineFull engineFullSchema =
194195
getDistributedEngineFull(
195196
connectionProvider.getOrCreateConnection(),

0 commit comments

Comments
 (0)