@@ -19,7 +19,7 @@
 package com.dtstack.flink.sql.sink.impala;
 
 import com.dtstack.flink.sql.classloader.ClassLoaderManager;
-import com.dtstack.flink.sql.core.rdb.util.JdbcConnectUtil;
+import com.dtstack.flink.sql.core.rdb.util.JdbcConnectionUtil;
 import com.dtstack.flink.sql.exception.ExceptionTrace;
 import com.dtstack.flink.sql.factory.DTThreadFactory;
 import com.dtstack.flink.sql.outputformat.AbstractDtRichOutputFormat;
@@ -283,8 +283,8 @@ private void executeUpdateBatch() throws SQLException {
             rows.clear();
         } catch (Exception e) {
             LOG.debug("impala jdbc execute batch error ", e);
-            JdbcConnectUtil.rollBack(connection);
-            JdbcConnectUtil.commit(connection);
+            JdbcConnectionUtil.rollBack(connection);
+            JdbcConnectionUtil.commit(connection);
             updateStatement.clearBatch();
             executeUpdate(connection);
         }
@@ -295,10 +295,10 @@ public void executeUpdate(Connection connection) {
             try {
                 setRecordToStatement(updateStatement, JDBCTypeConvertUtils.getSqlTypeFromFieldType(fieldTypes), row);
                 updateStatement.executeUpdate();
-                JdbcConnectUtil.commit(connection);
+                JdbcConnectionUtil.commit(connection);
             } catch (Exception e) {
-                JdbcConnectUtil.rollBack(connection);
-                JdbcConnectUtil.commit(connection);
+                JdbcConnectionUtil.rollBack(connection);
+                JdbcConnectionUtil.commit(connection);
                 if (metricOutputFormat.outDirtyRecords.getCount() % DIRTY_DATA_PRINT_FREQUENCY == 0 || LOG.isDebugEnabled()) {
                     LOG.error("record insert failed ,this row is {}", row.toString());
                     LOG.error("", e);
@@ -510,16 +510,16 @@ private void dealBatchSqlError(List<String> rowData,
                                    Statement statement,
                                    String templateSql) {
         String errorMsg = "Insert into impala error. \nCause: [%s]\nRow: [%s]";
-        JdbcConnectUtil.rollBack(connection);
-        JdbcConnectUtil.commit(connection);
+        JdbcConnectionUtil.rollBack(connection);
+        JdbcConnectionUtil.commit(connection);
         for (String rowDatum : rowData) {
             String executeSql = templateSql.replace(VALUES_CONDITION, rowDatum);
             try {
                 statement.execute(executeSql);
-                JdbcConnectUtil.commit(connection);
+                JdbcConnectionUtil.commit(connection);
             } catch (SQLException e) {
-                JdbcConnectUtil.rollBack(connection);
-                JdbcConnectUtil.commit(connection);
+                JdbcConnectionUtil.rollBack(connection);
+                JdbcConnectionUtil.commit(connection);
                 if (metricOutputFormat.outDirtyRecords.getCount() % DIRTY_DATA_PRINT_FREQUENCY == 0 || LOG.isDebugEnabled()) {
                     LOG.error(
                         String.format(