Skip to content

Commit 8f24dba

Browse files
authored
Merge pull request #199 from stuBirdFly/master
Resolved the issue where setting SetRpcExecuteTimeout for an HTable d…
2 parents a4f407c + 1317940 commit 8f24dba

File tree

1 file changed

+11
-0
lines changed

1 file changed

+11
-0
lines changed

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

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1061,6 +1061,17 @@ public String getIndexTableName(final String dataTableName, final String indexNa
10611061
return indexTableName;
10621062
}
10631063

1064+
@Override
1065+
public void setRpcExecuteTimeout(int rpcExecuteTimeout) {
1066+
this.properties.put(RPC_EXECUTE_TIMEOUT.getKey(), String.valueOf(rpcExecuteTimeout));
1067+
this.rpcExecuteTimeout = rpcExecuteTimeout;
1068+
for (ObTable obTable : tableRoster.values()) {
1069+
if (obTable != null) {
1070+
obTable.setObTableExecuteTimeout(rpcExecuteTimeout);
1071+
}
1072+
}
1073+
}
1074+
10641075
public String constructIndexTableName(final String dataTableName, final String indexName)
10651076
throws Exception {
10661077
// construct index table name

0 commit comments

Comments
 (0)