diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactRandomRegionOfTableAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactRandomRegionOfTableAction.java index c5680980734..e18f82ae96a 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactRandomRegionOfTableAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactRandomRegionOfTableAction.java @@ -66,12 +66,16 @@ public class CompactRandomRegionOfTableAction extends Action { HRegionInfo region = PolicyBasedChaosMonkey.selectRandomItem( regions.toArray(new HRegionInfo[regions.size()])); - if (major) { - LOG.debug("Major compacting region " + region.getRegionNameAsString()); - admin.majorCompact(region.getRegionName()); - } else { - LOG.debug("Compacting region " + region.getRegionNameAsString()); - admin.compact(region.getRegionName()); + try { + if (major) { + LOG.debug("Major compacting region " + region.getRegionNameAsString()); + admin.majorCompact(region.getRegionName()); + } else { + LOG.debug("Compacting region " + region.getRegionNameAsString()); + admin.compact(region.getRegionName()); + } + } catch (Exception ex) { + LOG.warn("Compaction failed, might be caused by other chaos: " + ex.getMessage()); } if (sleepTime > 0) { Thread.sleep(sleepTime); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactTableAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactTableAction.java index 775896198f2..1a3e151fbb5 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactTableAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactTableAction.java @@ -51,10 +51,14 @@ public class CompactTableAction extends Action { boolean major = RandomUtils.nextInt(100) < majorRatio; LOG.info("Performing action: Compact table " + tableName + ", major=" + major); - if (major) { - admin.majorCompact(tableNameBytes); - } else { - admin.compact(tableNameBytes); + try { + if (major) { + admin.majorCompact(tableNameBytes); + } else { + admin.compact(tableNameBytes); + } + } catch (Exception ex) { + LOG.warn("Compaction failed, might be caused by other chaos: " + ex.getMessage()); } if (sleepTime > 0) { Thread.sleep(sleepTime); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/FlushRandomRegionOfTableAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/FlushRandomRegionOfTableAction.java index a635a0f24d5..3012d68b882 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/FlushRandomRegionOfTableAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/FlushRandomRegionOfTableAction.java @@ -59,7 +59,11 @@ public class FlushRandomRegionOfTableAction extends Action { HRegionInfo region = PolicyBasedChaosMonkey.selectRandomItem( regions.toArray(new HRegionInfo[regions.size()])); LOG.debug("Flushing region " + region.getRegionNameAsString()); - admin.flush(region.getRegionName()); + try { + admin.flush(region.getRegionName()); + } catch (Exception ex) { + LOG.warn("Flush failed, might be caused by other chaos: " + ex.getMessage()); + } if (sleepTime > 0) { Thread.sleep(sleepTime); } diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/FlushTableAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/FlushTableAction.java index ced415338c0..e032165b296 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/FlushTableAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/FlushTableAction.java @@ -46,7 +46,11 @@ public class FlushTableAction extends Action { HBaseAdmin admin = util.getHBaseAdmin(); LOG.info("Performing action: Flush table " + tableName); - admin.flush(tableNameBytes); + try { + admin.flush(tableNameBytes); + } catch (Exception ex) { + LOG.warn("Flush failed, might be caused by other chaos: " + ex.getMessage()); + } if (sleepTime > 0) { Thread.sleep(sleepTime); } diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MergeRandomAdjacentRegionsOfTableAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MergeRandomAdjacentRegionsOfTableAction.java index 14c8a525a63..f5235d46c88 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MergeRandomAdjacentRegionsOfTableAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MergeRandomAdjacentRegionsOfTableAction.java @@ -60,7 +60,11 @@ public class MergeRandomAdjacentRegionsOfTableAction extends Action { HRegionInfo a = regions.get(i++); HRegionInfo b = regions.get(i); LOG.debug("Merging " + a.getRegionNameAsString() + " and " + b.getRegionNameAsString()); - admin.mergeRegions(a.getEncodedNameAsBytes(), b.getEncodedNameAsBytes(), false); + try { + admin.mergeRegions(a.getEncodedNameAsBytes(), b.getEncodedNameAsBytes(), false); + } catch (Exception ex) { + LOG.warn("Merge failed, might be caused by other chaos: " + ex.getMessage()); + } if (sleepTime > 0) { Thread.sleep(sleepTime); } diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MoveRegionsOfTableAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MoveRegionsOfTableAction.java index e9e1d0fbd34..4c5db1ef726 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MoveRegionsOfTableAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MoveRegionsOfTableAction.java @@ -74,8 +74,8 @@ public class MoveRegionsOfTableAction extends Action { servers[RandomUtils.nextInt(servers.length)].getServerName(); LOG.debug("Moving " + regionInfo.getRegionNameAsString() + " to " + destServerName); admin.move(regionInfo.getEncodedNameAsBytes(), Bytes.toBytes(destServerName)); - } catch (Exception e) { - LOG.debug("Error moving region", e); + } catch (Exception ex) { + LOG.warn("Move failed, might be caused by other chaos: " + ex.getMessage()); } if (sleepTime > 0) { Thread.sleep(sleepTime); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/SplitRandomRegionOfTableAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/SplitRandomRegionOfTableAction.java index 839d03dbc5c..0c0685cca09 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/SplitRandomRegionOfTableAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/SplitRandomRegionOfTableAction.java @@ -59,7 +59,11 @@ public class SplitRandomRegionOfTableAction extends Action { HRegionInfo region = PolicyBasedChaosMonkey.selectRandomItem( regions.toArray(new HRegionInfo[regions.size()])); LOG.debug("Splitting region " + region.getRegionNameAsString()); - admin.split(region.getRegionName()); + try { + admin.split(region.getRegionName()); + } catch (Exception ex) { + LOG.warn("Split failed, might be caused by other chaos: " + ex.getMessage()); + } if (sleepTime > 0) { Thread.sleep(sleepTime); }