1. 包列表
  2. 类列表
  3. org.apache.hadoop.hdfs.TestRollingUpgrade

Java 类org.apache.hadoop.hdfs.TestRollingUpgrade 实例源码

项目：hadoop    文件：TestDataNodeRollingUpgrade.java    
private void startRollingUpgrade() throws Exception {
  LOG.info("Starting rolling upgrade");
  fs.setSafeMode(SafeModeAction.SAFEMODE_ENTER);
  final DFSAdmin dfsadmin = new DFSAdmin(conf);
  TestRollingUpgrade.runCmd(dfsadmin, true, "-rollingUpgrade", "prepare");
  triggerHeartBeats();

  // Ensure datanode rolling upgrade is started
  assertTrue(dn0.getFSDataset().trashEnabled(blockPoolId));
}
项目：hadoop    文件：TestDataNodeRollingUpgrade.java    
private void finalizeRollingUpgrade() throws Exception {
  LOG.info("Finalizing rolling upgrade");
  final DFSAdmin dfsadmin = new DFSAdmin(conf);
  TestRollingUpgrade.runCmd(dfsadmin, true, "-rollingUpgrade", "finalize");
  triggerHeartBeats();

  // Ensure datanode rolling upgrade is started
  assertFalse(dn0.getFSDataset().trashEnabled(blockPoolId));
  BlockPoolSliceStorage bps = dn0.getStorage().getBPStorage(blockPoolId);
  assertFalse(bps.trashEnabled());
}
项目：aliyun-oss-hadoop-fs    文件：TestDataNodeRollingUpgrade.java    
private void startRollingUpgrade() throws Exception {
  LOG.info("Starting rolling upgrade");
  fs.setSafeMode(SafeModeAction.SAFEMODE_ENTER);
  final DFSAdmin dfsadmin = new DFSAdmin(conf);
  TestRollingUpgrade.runCmd(dfsadmin, true, "-rollingUpgrade", "prepare");
  triggerHeartBeats();

  // Ensure datanode rolling upgrade is started
  assertTrue(dn0.getFSDataset().trashEnabled(blockPoolId));
}
项目：aliyun-oss-hadoop-fs    文件：TestDataNodeRollingUpgrade.java    
private void finalizeRollingUpgrade() throws Exception {
  LOG.info("Finalizing rolling upgrade");
  final DFSAdmin dfsadmin = new DFSAdmin(conf);
  TestRollingUpgrade.runCmd(dfsadmin, true, "-rollingUpgrade", "finalize");
  triggerHeartBeats();

  // Ensure datanode rolling upgrade is started
  assertFalse(dn0.getFSDataset().trashEnabled(blockPoolId));
  BlockPoolSliceStorage bps = dn0.getStorage().getBPStorage(blockPoolId);
  assertFalse(bps.trashEnabled());
}
项目：big-c    文件：TestDataNodeRollingUpgrade.java    
private void startRollingUpgrade() throws Exception {
  LOG.info("Starting rolling upgrade");
  fs.setSafeMode(SafeModeAction.SAFEMODE_ENTER);
  final DFSAdmin dfsadmin = new DFSAdmin(conf);
  TestRollingUpgrade.runCmd(dfsadmin, true, "-rollingUpgrade", "prepare");
  triggerHeartBeats();

  // Ensure datanode rolling upgrade is started
  assertTrue(dn0.getFSDataset().trashEnabled(blockPoolId));
}
项目：big-c    文件：TestDataNodeRollingUpgrade.java    
private void finalizeRollingUpgrade() throws Exception {
  LOG.info("Finalizing rolling upgrade");
  final DFSAdmin dfsadmin = new DFSAdmin(conf);
  TestRollingUpgrade.runCmd(dfsadmin, true, "-rollingUpgrade", "finalize");
  triggerHeartBeats();

  // Ensure datanode rolling upgrade is started
  assertFalse(dn0.getFSDataset().trashEnabled(blockPoolId));
  BlockPoolSliceStorage bps = dn0.getStorage().getBPStorage(blockPoolId);
  assertFalse(bps.trashEnabled());
}
项目：hadoop-2.6.0-cdh5.4.3    文件：TestDataNodeRollingUpgrade.java    
private void startRollingUpgrade() throws Exception {
  LOG.info("Starting rolling upgrade");
  fs.setSafeMode(SafeModeAction.SAFEMODE_ENTER);
  final DFSAdmin dfsadmin = new DFSAdmin(conf);
  TestRollingUpgrade.runCmd(dfsadmin, true, "-rollingUpgrade", "prepare");
  triggerHeartBeats();

  // Ensure datanode rolling upgrade is started
  assertTrue(dn0.getFSDataset().trashEnabled(blockPoolId));
}
项目：hadoop-2.6.0-cdh5.4.3    文件：TestDataNodeRollingUpgrade.java    
private void finalizeRollingUpgrade() throws Exception {
  LOG.info("Finalizing rolling upgrade");
  final DFSAdmin dfsadmin = new DFSAdmin(conf);
  TestRollingUpgrade.runCmd(dfsadmin, true, "-rollingUpgrade", "finalize");
  triggerHeartBeats();

  // Ensure datanode rolling upgrade is started
  assertFalse(dn0.getFSDataset().trashEnabled(blockPoolId));
  BlockPoolSliceStorage bps = dn0.getStorage().getBPStorage(blockPoolId);
  assertFalse(bps.trashEnabled());
}
项目：FlexMap    文件：TestDataNodeRollingUpgrade.java    
private void startRollingUpgrade() throws Exception {
  LOG.info("Starting rolling upgrade");
  fs.setSafeMode(SafeModeAction.SAFEMODE_ENTER);
  final DFSAdmin dfsadmin = new DFSAdmin(conf);
  TestRollingUpgrade.runCmd(dfsadmin, true, "-rollingUpgrade", "prepare");
  triggerHeartBeats();

  // Ensure datanode rolling upgrade is started
  assertTrue(dn0.getFSDataset().trashEnabled(blockPoolId));
}
项目：FlexMap    文件：TestDataNodeRollingUpgrade.java    
private void finalizeRollingUpgrade() throws Exception {
  LOG.info("Finalizing rolling upgrade");
  final DFSAdmin dfsadmin = new DFSAdmin(conf);
  TestRollingUpgrade.runCmd(dfsadmin, true, "-rollingUpgrade", "finalize");
  triggerHeartBeats();

  // Ensure datanode rolling upgrade is started
  assertFalse(dn0.getFSDataset().trashEnabled(blockPoolId));
  BlockPoolSliceStorage bps = dn0.getStorage().getBPStorage(blockPoolId);
  assertFalse(bps.trashEnabled());
}
项目：hadoop-on-lustre2    文件：TestDataNodeRollingUpgrade.java    
private void startRollingUpgrade() throws Exception {
  LOG.info("Starting rolling upgrade");
  final DFSAdmin dfsadmin = new DFSAdmin(conf);
  TestRollingUpgrade.runCmd(dfsadmin, true, "-rollingUpgrade", "prepare");
  triggerHeartBeats();

  // Ensure datanode rolling upgrade is started
  assertTrue(dn.getFSDataset().trashEnabled(blockPoolId));
}
项目：hadoop-on-lustre2    文件：TestDataNodeRollingUpgrade.java    
private void finalizeRollingUpgrade() throws Exception {
  LOG.info("Finalizing rolling upgrade");
  final DFSAdmin dfsadmin = new DFSAdmin(conf);
  TestRollingUpgrade.runCmd(dfsadmin, true, "-rollingUpgrade", "finalize");
  triggerHeartBeats();

  // Ensure datanode rolling upgrade is started
  assertFalse(dn.getFSDataset().trashEnabled(blockPoolId));
  BlockPoolSliceStorage bps = dn.getStorage().getBPStorage(blockPoolId);
  assertFalse(bps.trashEnabled());
}