Index: src/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java =================================================================== --- src/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java (revision 930353) +++ src/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java (working copy) @@ -1495,7 +1495,7 @@ + e.msg.toString()); } } catch (InterruptedException ex) { - // continue + LOG.warn(ex); } catch (Exception ex) { if (ex instanceof IOException) { ex = RemoteExceptionHandler.checkIOException((IOException) ex); @@ -1764,7 +1764,6 @@ this.cacheFlusher.reclaimMemStoreMemory(); } region.put(put, getLockFromId(put.getLockId())); - } catch (Throwable t) { throw convertThrowableToIOE(cleanup(t)); } @@ -1792,7 +1791,8 @@ LOG.debug("Batch puts: " + i, ex); return i; } catch (NotServingRegionException ex) { - LOG.debug("Batch puts: " + i, ex); + LOG.debug("Batch puts interrupted at index=" + i + " because:" + + ex.getMessage()); return i; } catch (Throwable t) { throw convertThrowableToIOE(cleanup(t)); @@ -2519,8 +2519,6 @@ doMain(args, regionServerClass); } - - @Override public MultiPutResponse multiPut(MultiPut puts) throws IOException { MultiPutResponse resp = new MultiPutResponse(); @@ -2534,5 +2532,4 @@ return resp; } - } Index: src/java/org/apache/hadoop/hbase/regionserver/HRegion.java =================================================================== --- src/java/org/apache/hadoop/hbase/regionserver/HRegion.java (revision 930353) +++ src/java/org/apache/hadoop/hbase/regionserver/HRegion.java (working copy) @@ -1711,7 +1711,7 @@ splitsAndClosesLock.readLock().lock(); try { if (this.closed.get()) { - throw new NotServingRegionException("Region " + this + " closed"); + throw new NotServingRegionException(this + " is closed"); } synchronized (lockedRows) { while (lockedRows.contains(row)) {