List of stopRegionServer() Examples

Examples of stopRegionServer()

org.apache.hadoop.hbase.MiniHBaseCluster.stopRegionServer()
Shut down the specified region server cleanly @param serverNumber Used as index into a list. @return the region server that was stopped

Examples of org.apache.hadoop.hbase.MiniHBaseCluster.stopRegionServer()

    MiniHBaseCluster peerCluster = utility2.getMiniHBaseCluster();


    doPutTest(Bytes.toBytes(1));


    int rsToStop = peerCluster.getServerWithMeta() == 0 ? 1 : 0;
    peerCluster.stopRegionServer(rsToStop);
    peerCluster.waitOnRegionServer(rsToStop);


    // Sanity check
    assertEquals(1, peerCluster.getRegionServerThreads().size());

View Full Code Here

Examples of org.apache.hadoop.hbase.MiniHBaseCluster.stopRegionServer()


      int nrs = miniCluster.getRegionServerThreads().size();


      // Stop a Region Server
      listener.reset();
      miniCluster.stopRegionServer(nrs - 1);
      listener.awaitModifications(1);
      assertEquals(0, listener.getAddedCount());
      assertEquals(1, listener.getRemovedCount());


      // Stop another Region Server

View Full Code Here

Examples of org.apache.hadoop.hbase.MiniHBaseCluster.stopRegionServer()

      assertEquals(0, listener.getAddedCount());
      assertEquals(1, listener.getRemovedCount());


      // Stop another Region Server
      listener.reset();
      miniCluster.stopRegionServer(nrs - 2);
      listener.awaitModifications(1);
      assertEquals(0, listener.getAddedCount());
      assertEquals(1, listener.getRemovedCount());
    } finally {
      serverManager.unregisterListener(listener);

View Full Code Here

Examples of org.apache.hadoop.hbase.MiniHBaseCluster.stopRegionServer()

    MiniHBaseCluster peerCluster = utility2.getMiniHBaseCluster();


    doPutTest(Bytes.toBytes(1));


    int rsToStop = peerCluster.getServerWithMeta() == 0 ? 1 : 0;
    peerCluster.stopRegionServer(rsToStop);
    peerCluster.waitOnRegionServer(rsToStop);


    // Sanity check
    assertEquals(1, peerCluster.getRegionServerThreads().size());

View Full Code Here

Examples of org.apache.hadoop.hbase.MiniHBaseCluster.stopRegionServer()

    checkExistence(htable, row, FAMILY, QUALIFIER1, VALUE1);


    // Now let's shutdown the regionserver and let regions moved to other servers.
    HRegionLocation loc = htable.getRegionLocation(row);
    MiniHBaseCluster hbaseCluster = TEST_UTIL.getHBaseCluster(); 
    hbaseCluster.stopRegionServer(loc.getServerName());
    TEST_UTIL.waitUntilAllRegionsAssigned(TABLE);


    // put with multiplexer.
    put = new Put(row).add(FAMILY, QUALIFIER2, VALUE2);
    assertTrue("multiplexer.put returns", multiplexer.put(TABLE, put));

View Full Code Here

Examples of org.apache.hadoop.hbase.MiniHBaseCluster.stopRegionServer()

    MiniHBaseCluster peerCluster = utility2.getMiniHBaseCluster();


    doPutTest(Bytes.toBytes(1));


    int rsToStop = peerCluster.getServerWithMeta() == 0 ? 1 : 0;
    peerCluster.stopRegionServer(rsToStop);
    peerCluster.waitOnRegionServer(rsToStop);


    // Sanity check
    assertEquals(1, peerCluster.getRegionServerThreads().size());

View Full Code Here

Examples of org.apache.hadoop.hbase.MiniHBaseCluster.stopRegionServer()


      int nrs = miniCluster.getRegionServerThreads().size();


      // Stop a Region Server
      listener.reset();
      miniCluster.stopRegionServer(nrs - 1);
      listener.awaitModifications(1);
      assertEquals(0, listener.getAddedCount());
      assertEquals(1, listener.getRemovedCount());


      // Stop another Region Server

View Full Code Here

Examples of org.apache.hadoop.hbase.MiniHBaseCluster.stopRegionServer()

      assertEquals(0, listener.getAddedCount());
      assertEquals(1, listener.getRemovedCount());


      // Stop another Region Server
      listener.reset();
      miniCluster.stopRegionServer(nrs - 2);
      listener.awaitModifications(1);
      assertEquals(0, listener.getAddedCount());
      assertEquals(1, listener.getRemovedCount());
    } finally {
      serverManager.unregisterListener(listener);

View Full Code Here

Examples of org.apache.hadoop.hbase.MiniHBaseCluster.stopRegionServer()


      int nrs = miniCluster.getRegionServerThreads().size();


      // Stop a Region Server
      listener.reset();
      miniCluster.stopRegionServer(nrs - 1);
      listener.awaitModifications(1);
      assertEquals(0, listener.getAddedCount());
      assertEquals(1, listener.getRemovedCount());


      // Stop another Region Server

View Full Code Here

Examples of org.apache.hadoop.hbase.MiniHBaseCluster.stopRegionServer()

      assertEquals(0, listener.getAddedCount());
      assertEquals(1, listener.getRemovedCount());


      // Stop another Region Server
      listener.reset();
      miniCluster.stopRegionServer(nrs - 2);
      listener.awaitModifications(1);
      assertEquals(0, listener.getAddedCount());
      assertEquals(1, listener.getRemovedCount());
    } finally {
      serverManager.unregisterListener(listener);

View Full Code Here

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.