Skip to content

Commit 49624ba

Browse files
authored
set request timeout to new hbase put; lengthen the rs connect timeout (#403)
1 parent 43f214c commit 49624ba

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2428,7 +2428,9 @@ public ObPayload execute(final ObHbaseRequest request) throws Exception {
24282428
throw new IllegalArgumentException("table name is null");
24292429
}
24302430
if (isOdpMode()) {
2431-
return getOdpTable().execute(request);
2431+
ObTable obTable = getOdpTable();
2432+
request.setTimeout(obTable.getObTableOperationTimeout());
2433+
return obTable.execute(request);
24322434
} else {
24332435
Row row = new Row();
24342436
// get the first cell from the first cfRows to route

src/main/java/com/alipay/oceanbase/rpc/property/Property.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ public enum Property {
4141
METADATA_REFRESH_LOCK_TIMEOUT("metadata.refresh.lock.timeout", 8000L, "刷新METADATA的锁超时时间"),
4242

4343
// [ObTableClient][RS_LIST]
44-
RS_LIST_ACQUIRE_CONNECT_TIMEOUT("rs.list.acquire.connect.timeout", 200, "获取RS列表的建连的超时时间"),
44+
RS_LIST_ACQUIRE_CONNECT_TIMEOUT("rs.list.acquire.connect.timeout", 1000, "获取RS列表的建连的超时时间"),
4545

4646
RS_LIST_ACQUIRE_READ_TIMEOUT("rs.list.acquire.read.timeout", 1000, "获取RS列表的读取的超时时间"),
4747

0 commit comments

Comments
 (0)