Skip to content

Commit 33dd840

Browse files
committed
add setRuntimeMaxWait and setRuntimeBatchMaxWait in OHTable setOperationTimeout
1 parent b32c7e1 commit 33dd840

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/main/java/com/alipay/oceanbase/hbase/OHTable.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1742,6 +1742,8 @@ public <R extends Message> void batchCoprocessorService(Descriptors.MethodDescri
17421742
@Override
17431743
public void setOperationTimeout(int operationTimeout) {
17441744
this.operationTimeout = operationTimeout;
1745+
this.obTableClient.setRuntimeMaxWait(operationTimeout);
1746+
this.obTableClient.setRuntimeBatchMaxWait(operationTimeout);
17451747
this.operationExecuteInPool = this.configuration.getBoolean(
17461748
HBASE_CLIENT_OPERATION_EXECUTE_IN_POOL,
17471749
(this.operationTimeout != HConstants.DEFAULT_HBASE_CLIENT_OPERATION_TIMEOUT));

0 commit comments

Comments
 (0)