diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestImportTsv.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestImportTsv.java index cfeb3dc..a24e70b 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestImportTsv.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestImportTsv.java @@ -123,11 +123,18 @@ public class IntegrationTestImportTsv implements Configurable, Tool { util = new IntegrationTestingUtility(); } util.initializeCluster(1); + if (!util.isDistributedCluster()) { + // also need MR when running without a real cluster + util.startMiniMapReduceCluster(); + } } @AfterClass public static void releaseCluster() throws Exception { util.restoreCluster(); + if (!util.isDistributedCluster()) { + util.shutdownMiniMapReduceCluster(); + } util = null; }