diff --git a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/ConnectionFactory.java b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/ConnectionFactory.java
index 3aef46b3..8f177bac 100644
--- a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/ConnectionFactory.java
+++ b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/ConnectionFactory.java
@@ -7,9 +7,9 @@ import java.sql.Connection;
  */
 public interface ConnectionFactory {
 
-    public Connection getConnecttion();
+    public Connection getConnection();
 
-    public Connection getConnecttionWithoutRetry();
+    public Connection getConnectionWithoutRetry();
 
     public String getConnectionInfo();
 
diff --git a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/JdbcConnectionFactory.java b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/JdbcConnectionFactory.java
index 2fe3108e..0404ea1b 100644
--- a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/JdbcConnectionFactory.java
+++ b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/JdbcConnectionFactory.java
@@ -23,12 +23,12 @@ public class JdbcConnectionFactory implements ConnectionFactory {
     }
 
     @Override
-    public Connection getConnecttion() {
+    public Connection getConnection() {
         return DBUtil.getConnection(dataBaseType, jdbcUrl, userName, password);
     }
 
     @Override
-    public Connection getConnecttionWithoutRetry() {
+    public Connection getConnectionWithoutRetry() {
         return DBUtil.getConnectionWithoutRetry(dataBaseType, jdbcUrl, userName, password);
     }
 
diff --git a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/writer/util/OriginalConfPretreatmentUtil.java b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/writer/util/OriginalConfPretreatmentUtil.java
index 556e50ac..04bf479f 100755
--- a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/writer/util/OriginalConfPretreatmentUtil.java
+++ b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/writer/util/OriginalConfPretreatmentUtil.java
@@ -101,9 +101,9 @@ public final class OriginalConfPretreatmentUtil {
             boolean isPreCheck = originalConfig.getBool(Key.DRYRUN, false);
             List<String> allColumns;
             if (isPreCheck){
-                allColumns = DBUtil.getTableColumnsByConn(DATABASE_TYPE,connectionFactory.getConnecttionWithoutRetry(), oneTable, connectionFactory.getConnectionInfo());
+                allColumns = DBUtil.getTableColumnsByConn(DATABASE_TYPE,connectionFactory.getConnectionWithoutRetry(), oneTable, connectionFactory.getConnectionInfo());
             }else{
-                allColumns = DBUtil.getTableColumnsByConn(DATABASE_TYPE,connectionFactory.getConnecttion(), oneTable, connectionFactory.getConnectionInfo());
+                allColumns = DBUtil.getTableColumnsByConn(DATABASE_TYPE,connectionFactory.getConnection(), oneTable, connectionFactory.getConnectionInfo());
             }
 
             LOG.info("table:[{}] all columns:[\n{}\n].", oneTable,
@@ -123,7 +123,7 @@ public final class OriginalConfPretreatmentUtil {
                 ListUtil.makeSureNoValueDuplicate(userConfiguredColumns, false);
                 Connection connection = null;
                 try {
-                    connection = connectionFactory.getConnecttion();
+                    connection = connectionFactory.getConnection();
                     // 检查列是否都为数据库表中正确的列（通过执行一次 select column from table 进行判断）
                     DBUtil.getColumnMetaData(connection, oneTable,StringUtils.join(userConfiguredColumns, ","));
                 } finally {