Skip to content

Commit eda374d

Browse files
committed
[Hotfix][Connector-V2][Jdbc] Flink engine, source is LocalFile, sink is jdbc, get "No suitable driver" Exception fix (#6902)
1 parent 35df14d commit eda374d

File tree

1 file changed

+1
-0
lines changed
  • seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink

1 file changed

+1
-0
lines changed

seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkWriter.java

+1
Original file line numberDiff line numberDiff line change
@@ -88,6 +88,7 @@ public MultiTableResourceManager<ConnectionPoolManager> initMultiTableResourceMa
8888
ds.setPassword(jdbcSinkConfig.getJdbcConnectionConfig().getPassword().get());
8989
}
9090
ds.setAutoCommit(jdbcSinkConfig.getJdbcConnectionConfig().isAutoCommit());
91+
ds.setDriverClassName(jdbcSinkConfig.getJdbcConnectionConfig().getDriverName());
9192
return new JdbcMultiTableResourceManager(new ConnectionPoolManager(ds));
9293
}
9394

0 commit comments

Comments
 (0)