diff --git a/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/InsertTask.java b/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/InsertTask.java
index 522d91a5..36fc726b 100644
--- a/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/InsertTask.java
+++ b/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/InsertTask.java
@@ -65,6 +65,7 @@ public class InsertTask implements Runnable {
 		this.writeRecordSql = writeRecordSql;
 		this.isStop = false;
 		this.deleteMeta = deleteMeta;
+		connHolder.initConnection();
 	}
 	
 	void setWriterTask(ConcurrentTableWriterTask writerTask) {
@@ -151,7 +152,6 @@ public class InsertTask implements Runnable {
 
 	public void doMultiInsert(final List<Record> buffer, final boolean printCost, final long restrict) {
 		checkMemstore();
-		connHolder.initConnection();
 		Connection conn = connHolder.getConn();
 		boolean success = false;
 		long cost = 0;