This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-spark-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 00759cb [fix](connector) fix no suitable driver found issue when
getting fe jdbc connection (#251)
00759cb is described below
commit 00759cbd2f098a228bf0d43eceab1ab2989e47d4
Author: gnehil <[email protected]>
AuthorDate: Mon Jan 6 15:08:31 2025 +0800
[fix](connector) fix no suitable driver found issue when getting fe jdbc
connection (#251)
---
.../main/java/org/apache/doris/spark/client/DorisFrontendClient.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/DorisFrontendClient.java
b/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/DorisFrontendClient.java
index 12fc812..67b510e 100644
---
a/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/DorisFrontendClient.java
+++
b/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/DorisFrontendClient.java
@@ -173,6 +173,11 @@ public class DorisFrontendClient implements Serializable {
ex = new
OptionRequiredException(DorisOptions.DORIS_QUERY_PORT.getName());
break;
}
+ try {
+ Class.forName("com.mysql.cj.jdbc.Driver");
+ } catch (ClassNotFoundException e) {
+ Class.forName("com.mysql.jdbc.Driver");
+ }
try (Connection conn = DriverManager.getConnection("jdbc:mysql://"
+ frontEnd.getHost() + ":" + frontEnd.getQueryPort(), username, password)) {
return function.apply(conn);
} catch (SQLException e) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
