From 5d8bca4ccf451acb9a24e981fc72ff527afd24e3 Mon Sep 17 00:00:00 2001
From: "suz.yang" <suzhi.yt@antgroup.com>
Date: Wed, 31 Dec 2025 10:18:09 +0800
Subject: [PATCH] fix direct load p2p resume 2 (#430)

---
 .../oceanbase/rpc/direct_load/ObDirectLoadStatement.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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() {