diff --git a/src/main/java/org/apache/hadoop/hbase/regionserver/Compactor.java b/src/main/java/org/apache/hadoop/hbase/regionserver/Compactor.java index 2f9fa3623ec..12cc99f523d 100644 --- a/src/main/java/org/apache/hadoop/hbase/regionserver/Compactor.java +++ b/src/main/java/org/apache/hadoop/hbase/regionserver/Compactor.java @@ -197,7 +197,7 @@ class Compactor extends Configured { writer.close(); store.getFileSystem().delete(writer.getPath(), false); throw new InterruptedIOException( "Aborting compaction of store " + store + - " in region " + store.getHRegion() + " because user requested stop."); + " in region " + store.getHRegion() + " because it was interrupted."); } CompactionProgress getProgress() { diff --git a/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java b/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java index 266ef46e3bf..f5ee9b07be2 100644 --- a/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java +++ b/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java @@ -1298,7 +1298,7 @@ public class HRegion implements HeapSize { // , Writable{ status.setStatus("Compacting store " + cr.getStore()); cr.getStore().compact(cr); } catch (InterruptedIOException iioe) { - String msg = "compaction interrupted by user"; + String msg = "compaction interrupted"; LOG.info(msg, iioe); status.abort(msg); return false;