HBASE-19988 Fixed chatty log from HRegion#lockRowsAndBuildMiniBatch() when interrupted while waiting on a row lock
This commit is contained in:
parent
9f27fdaffc
commit
70d3413ee2
|
@ -3166,8 +3166,10 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi
|
||||||
try {
|
try {
|
||||||
// if atomic then get exclusive lock, else shared lock
|
// if atomic then get exclusive lock, else shared lock
|
||||||
rowLock = region.getRowLockInternal(mutation.getRow(), !isAtomic(), prevRowLock);
|
rowLock = region.getRowLockInternal(mutation.getRow(), !isAtomic(), prevRowLock);
|
||||||
} catch (TimeoutIOException e) {
|
} catch (TimeoutIOException|InterruptedIOException e) {
|
||||||
// We will retry when other exceptions, but we should stop if we timeout .
|
// NOTE: We will retry when other exceptions, but we should stop if we receive
|
||||||
|
// TimeoutIOException or InterruptedIOException as operation has timed out or
|
||||||
|
// interrupted respectively.
|
||||||
throw e;
|
throw e;
|
||||||
} catch (IOException ioe) {
|
} catch (IOException ioe) {
|
||||||
LOG.warn("Failed getting lock, row=" + Bytes.toStringBinary(mutation.getRow()), ioe);
|
LOG.warn("Failed getting lock, row=" + Bytes.toStringBinary(mutation.getRow()), ioe);
|
||||||
|
|
Loading…
Reference in New Issue