Skip to content

Commit 5d8bca4

Browse files
committed
fix direct load p2p resume 2 (oceanbase#430)
1 parent b6f3478 commit 5d8bca4

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/main/java/com/alipay/oceanbase/rpc/direct_load/ObDirectLoadStatement.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -88,12 +88,12 @@ public synchronized void init(Builder builder) throws ObDirectLoadException {
8888
obTablePool = new ObDirectLoadConnection.ObTablePool(connection, logger, queryTimeout);
8989
obTablePool.init();
9090
executor = new ObDirectLoadStatementExecutor(this, builder.isP2PMode);
91-
if (builder.executionId != null) {
92-
executor.resume(builder.executionId);
93-
}
9491
startQueryTimeMillis = System.currentTimeMillis();
9592
isInited = true;
9693
logger.info("statement init successful, args:" + builder);
94+
if (builder.executionId != null) {
95+
executor.resume(builder.executionId);
96+
}
9797
}
9898

9999
public synchronized void close() {

0 commit comments

Comments
 (0)