Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-26027 The calling of HTable.batch blocked at AsyncRequestFuture… (#3419) 

* HBASE-26027 The calling of HTable.batch blocked at AsyncRequestFutureImpl.waitUntilDone caused by ArrayStoreException

(cherry picked from commit 1d6eb77ef8)
This commit is contained in:
bsglz 2021-07-01 19:16:51 +08:00
parent c50867348b
commit fe6c75cb50
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRequestFutureImpl.java
View File

@ -1140,7 +1140,15 @@ class AsyncRequestFutureImpl<CResult> implements AsyncRequestFuture {
@Override @Override
public void waitUntilDone() throws InterruptedIOException { public void waitUntilDone() throws InterruptedIOException {
try { try {
waitUntilDone(Long.MAX_VALUE); if (this.operationTimeout > 0) {
// the worker thread maybe over by some exception without decrement the actionsInProgress,
// then the guarantee of operationTimeout will be broken, so we should set cutoff to avoid
// stuck here forever
long cutoff = (EnvironmentEdgeManager.currentTime() + this.operationTimeout) * 1000L;
waitUntilDone(cutoff);
} else {
waitUntilDone(Long.MAX_VALUE);
}
} catch (InterruptedException iex) { } catch (InterruptedException iex) {
throw new InterruptedIOException(iex.getMessage()); throw new InterruptedIOException(iex.getMessage());
} finally { } finally {