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("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();
  }
}

View Full Code Here

      assertTrue(uniqueBlocksWeight1 == uniqueBlocksWeight2);


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


  /**

View Full Code Here

      assertTrue(uniqueBlocksWeight1 == uniqueBlocksWeight2);


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


  /**

View Full Code Here

        }
      }
      assertTrue(verified);
    } finally {
      htu1.shutdownMiniMapReduceCluster();
      htu1.shutdownMiniCluster();
    }
  }


  @Test
  public void testBulkOutputWithoutAnExistingTable() throws Exception {

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();
  }


  /**
   * Simple test of master failover.
   * <p>

View Full Code Here

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


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

View Full Code Here

      assertTrue(uniqueBlocksWeight1 == uniqueBlocksWeight2);


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


  /**

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.