diff --git a/src/main/java/com/alipay/oceanbase/rpc/direct_load/execution/ObDirectLoadStatementExecutor.java b/src/main/java/com/alipay/oceanbase/rpc/direct_load/execution/ObDirectLoadStatementExecutor.java
index 4399d3c3..ee28304a 100644
--- a/src/main/java/com/alipay/oceanbase/rpc/direct_load/execution/ObDirectLoadStatementExecutor.java
+++ b/src/main/java/com/alipay/oceanbase/rpc/direct_load/execution/ObDirectLoadStatementExecutor.java
@@ -196,7 +196,6 @@ public synchronized void resume(ObDirectLoadStatementExecutionId executionId)
         try {
             if (NodeRole.P2P == nodeRole) {
                 compareAndSetState(NONE, LOADING, "resume in P2P mode");
-                startHeartBeat();
             } else {
                 nodeRole = NodeRole.WRITE_ONLY;
                 compareAndSetState(NONE, LOADING_ONLY, "resume");
@@ -208,6 +207,9 @@ public synchronized void resume(ObDirectLoadStatementExecutionId executionId)
         tableId = executionId.getTableId();
         taskId = executionId.getTaskId();
         svrAddr = executionId.getSvrAddr();
+        if (NodeRole.P2P == nodeRole) {
+            startHeartBeat();
+        }
     }
 
     public void close() {