Skip to content

Commit 39f3946

Browse files
authored
fix direct load p2p resume (#424)
1 parent 22cb5b8 commit 39f3946

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/main/java/com/alipay/oceanbase/rpc/direct_load/execution/ObDirectLoadStatementExecutor.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -196,7 +196,6 @@ public synchronized void resume(ObDirectLoadStatementExecutionId executionId)
196196
try {
197197
if (NodeRole.P2P == nodeRole) {
198198
compareAndSetState(NONE, LOADING, "resume in P2P mode");
199-
startHeartBeat();
200199
} else {
201200
nodeRole = NodeRole.WRITE_ONLY;
202201
compareAndSetState(NONE, LOADING_ONLY, "resume");
@@ -208,6 +207,9 @@ public synchronized void resume(ObDirectLoadStatementExecutionId executionId)
208207
tableId = executionId.getTableId();
209208
taskId = executionId.getTaskId();
210209
svrAddr = executionId.getSvrAddr();
210+
if (NodeRole.P2P == nodeRole) {
211+
startHeartBeat();
212+
}
211213
}
212214

213215
public void close() {

0 commit comments

Comments
 (0)