Package org.apache.hadoop.hbase

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

148
149
150
151
152
153
154
155
        LOG.debug("Waiting on regionserver to abort..");
      }
    }

    // cleanup
    util.shutdownMiniCluster();
  }
}
View Full Code Here
251
252
253
254
255
256
257
258
259
260
261
    // cleanup
    scanner.close();
    index.close();
    primary.close();
    util.shutdownMiniCluster();
  }

  /**
   * @param miniHBaseCluster
   * @param server
View Full Code Here
144
145
146
147
148
149
150
151
152
153
154
      }

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

  private void runScanner(Table table, boolean slow) throws Exception {
View Full Code Here
98
99
100
101
102
103
104
105
106
107
108
      assertEquals(onlineServersList.size(), 2);
      cluster.shutdown();
    } finally {
      masterActive = false;
      firstRS.set(true);
      TEST_UTIL.shutdownMiniCluster();
    }
  }

  public static class MockedRegionServer extends MiniHBaseCluster.MiniHBaseClusterRegionServer {
View Full Code Here
190
191
192
193
194
195
196
197
198
199
200
    // TODO: Bring random 3 of 4 RS down at the same time

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

  private void blockUntilNoRIT(ZooKeeperWatcher zkw, HMaster master)
  throws KeeperException, InterruptedException {
    ZKAssign.blockUntilNoRIT(zkw);
View Full Code Here
4091
4092
4093
4094
4095
4096
4097
4098
4099
4100
4101
      assertTrue(uniqueBlocksWeight1 == uniqueBlocksWeight2);

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

  /**
 
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
      cluster.waitOnMaster(i);
    }
    // make sure all the masters properly shutdown
    assertEquals(0,masterThreads.size());
   
    TEST_UTIL.shutdownMiniCluster();
  }

  @Test(timeout = 180000)
  public void testMasterShutdownBeforeStartingAnyRegionServer() throws Exception {
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
    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
197
198
199
200
201
202
203
204
205
206
207
        }
      } finally {
        in.close();
      }
    } finally {
      testUtil.shutdownMiniCluster();
    }
  }

  /**
   * Write up to 'size' bytes with value 'v' into a new file called 'path'.
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
          6, regions.size());
    assertTrue("The table should be in enabled state", cluster.getMaster()
        .getAssignmentManager().getTableStateManager()
        .isTableState(TableName.valueOf("tableRestart"), ZooKeeperProtos.Table.State.ENABLED));
    ht.close();
    TEST_UTIL.shutdownMiniCluster();
  }

  private void log(String msg) {
    LOG.debug("\n\nTRR: " + msg + "\n");
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.