diff --git a/src/main/java/com/alipay/oceanbase/rpc/direct_load/ObDirectLoadStatement.java b/src/main/java/com/alipay/oceanbase/rpc/direct_load/ObDirectLoadStatement.java
index f72ab6e0..71324255 100644
--- a/src/main/java/com/alipay/oceanbase/rpc/direct_load/ObDirectLoadStatement.java
+++ b/src/main/java/com/alipay/oceanbase/rpc/direct_load/ObDirectLoadStatement.java
@@ -88,12 +88,12 @@ public synchronized void init(Builder builder) throws ObDirectLoadException {
         obTablePool = new ObDirectLoadConnection.ObTablePool(connection, logger, queryTimeout);
         obTablePool.init();
         executor = new ObDirectLoadStatementExecutor(this, builder.isP2PMode);
-        if (builder.executionId != null) {
-            executor.resume(builder.executionId);
-        }
         startQueryTimeMillis = System.currentTimeMillis();
         isInited = true;
         logger.info("statement init successful, args:" + builder);
+        if (builder.executionId != null) {
+            executor.resume(builder.executionId);
+        }
     }
 
     public synchronized void close() {