Examples of org.apache.hadoop.hbase.HBaseTestingUtility.shutdownMiniCluster()

Class org.apache.hadoop.hbase.HBaseTestingUtility

Examples of org.apache.hadoop.hbase.HBaseTestingUtility.shutdownMiniCluster()

org.apache.hadoop.hbase.HBaseTestingUtility.shutdownMiniCluster()
Stops mini hbase, zk, and hdfs clusters. @throws IOException @see {@link #startMiniCluster(int)}

        LOG.debug("Waiting on regionserver to abort..");
      }
    }


    // cleanup
    util.shutdownMiniCluster();
  }
}

View Full Code Here


    // cleanup
    scanner.close();
    index.close();
    primary.close();
    util.shutdownMiniCluster();
  }


  /**
   * @param miniHBaseCluster
   * @param server

View Full Code Here

      assertTrue(uniqueBlocksWeight1 == uniqueBlocksWeight2);


      ht.close();
    } finally {
      if (cluster != null) {
        htu.shutdownMiniCluster();
      }
    }
  }


  /**

View Full Code Here

    }


    log("Done with verification, all passed, shutting down cluster");


    // Done, shutdown the cluster
    TEST_UTIL.shutdownMiniCluster();
  }


  /**
   * Complex test of master failover that tests as many permutations of the
   * different possible states that regions in transition could be in within ZK

View Full Code Here

    }


    log("Done with verification, all passed, shutting down cluster");


    // Done, shutdown the cluster
    TEST_UTIL.shutdownMiniCluster();
  }


  /**
   * Verify regions are on the expected region server
   */

View Full Code Here

    log("Waiting for no more RIT");
    ZKAssign.blockUntilNoRIT(zkw);


    zkw.close();
    // Stop the cluster
    TEST_UTIL.shutdownMiniCluster();
  }


  /**
   * This tests a RIT in offline state will get re-assigned after a master restart
   */

View Full Code Here

    LOG.info("Active master " + mastername.getServerName() + " managing " +
      rss +  " region servers");
    assertEquals(3, rss);


    // Stop the cluster
    TEST_UTIL.shutdownMiniCluster();
  }


  /**
   * Test region in pending_open/close when master failover
   */

View Full Code Here

    assertTrue(regionStates.isRegionOnline(hriOnline));


    log("Done with verification, shutting down cluster");


    // Done, shutdown the cluster
    TEST_UTIL.shutdownMiniCluster();
  }
}

View Full Code Here

    assertEquals("hdfs", fs.getUri().getScheme());


    try {
      testLinkReadDuringRename(fs, testUtil.getDefaultRootDirPath());
    } finally {
      testUtil.shutdownMiniCluster();
    }
  }


  /**
   * Test, on a local filesystem, that the FileLink is still readable

View Full Code Here

        }
      } finally {
        in.close();
      }
    } finally {
      testUtil.shutdownMiniCluster();
    }
  }


  /**
   * Write up to 'size' bytes with value 'v' into a new file called 'path'.

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.