From 3a9a2d195d8f171562f441264455486df30f030a Mon Sep 17 00:00:00 2001
From: "suz.yang" <suzhi.yt@antgroup.com>
Date: Thu, 25 Dec 2025 11:12:47 +0800
Subject: [PATCH] fix direct load p2p resume (#424)

---
 .../direct_load/execution/ObDirectLoadStatementExecutor.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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