diff --git a/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HoodieHiveClient.java b/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HoodieHiveClient.java index 0bd388e70c96f..6d85395d3f6e5 100644 --- a/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HoodieHiveClient.java +++ b/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HoodieHiveClient.java @@ -38,7 +38,6 @@ import org.apache.hadoop.hive.ql.metadata.HiveException; import org.apache.hadoop.hive.ql.processors.CommandProcessorResponse; import org.apache.hadoop.hive.ql.session.SessionState; -import org.apache.hive.jdbc.HiveDriver; import org.apache.hudi.sync.common.AbstractSyncHoodieClient; import org.apache.log4j.LogManager; import org.apache.log4j.Logger; @@ -62,18 +61,8 @@ public class HoodieHiveClient extends AbstractSyncHoodieClient { private static final String HOODIE_LAST_COMMIT_TIME_SYNC = "last_commit_time_sync"; - // Make sure we have the hive JDBC driver in classpath - private static String driverName = HiveDriver.class.getName(); private static final String HIVE_ESCAPE_CHARACTER = HiveSchemaUtil.HIVE_ESCAPE_CHARACTER; - static { - try { - Class.forName(driverName); - } catch (ClassNotFoundException e) { - throw new IllegalStateException("Could not find " + driverName + " in classpath. ", e); - } - } - private static final Logger LOG = LogManager.getLogger(HoodieHiveClient.class); private final PartitionValueExtractor partitionValueExtractor; private IMetaStoreClient client; @@ -426,7 +415,7 @@ private List updateHiveSQLs(List sqls) { private void createHiveConnection() { if (connection == null) { try { - Class.forName(HiveDriver.class.getCanonicalName()); + Class.forName("org.apache.hive.jdbc.HiveDriver"); } catch (ClassNotFoundException e) { LOG.error("Unable to load Hive driver class", e); return;