Skip to content

Commit a622364

Browse files
WeiXinChanmedcll
authored andcommitted
modify direct-load MAX_QUERY_TIMEOUT to INT_MAX
1 parent 6a01518 commit a622364

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

src/main/java/com/alipay/oceanbase/rpc/bolt/transport/ObTableRemoting.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -199,6 +199,7 @@ private boolean needFetchAll(int errorCode, int pcode) {
199199
|| errorCode == ResultCodes.OB_SNAPSHOT_DISCARDED.errorCode
200200
|| errorCode == ResultCodes.OB_SCHEMA_EAGAIN.errorCode
201201
|| errorCode == ResultCodes.OB_ERR_WAIT_REMOTE_SCHEMA_REFRESH.errorCode
202+
|| errorCode == ResultCodes.OB_GTS_NOT_READY.errorCode
202203
|| (pcode == Pcodes.OB_TABLE_API_LS_EXECUTE && errorCode == ResultCodes.OB_NOT_MASTER.errorCode);
203204
}
204205

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -309,7 +309,7 @@ public static final class Builder {
309309
private long maxErrorRowCount = 0;
310310
private String loadMethod = "full";
311311

312-
private static final long MAX_QUERY_TIMEOUT = 1L * 365 * 24 * 3600 * 1000; // 1year
312+
private static final long MAX_QUERY_TIMEOUT = 2147483647; // INT_MAX
313313

314314
Builder(ObDirectLoadConnection connection) {
315315
this.connection = connection;

0 commit comments

Comments
 (0)