diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java index 95bed0e..b617a4e 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java +++ hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java @@ -2589,17 +2589,11 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver { // try { rowLock = getRowLock(mutation.getRow(), shouldBlock); } catch (IOException ioe) { - LOG.warn("Failed getting lock in batch put, row=" + throw new IOException("Failed getting lock in batch put, row=" + Bytes.toStringBinary(mutation.getRow()), ioe); } - if (rowLock == null) { - // We failed to grab another lock - assert !shouldBlock : "Should never fail to get lock when blocking"; - break; // stop acquiring more rows for this batch - } else { - acquiredRowLocks.add(rowLock); - } - + acquiredRowLocks.add(rowLock); + lastIndexExclusive++; numReadyToWrite++;