import org.apache.hadoop.hdfs.tools.DFSHAAdmin; //导入依赖的package包/类
@Test(timeout=30000)
public void testManualFailoverWithDFSHAAdmin() throws Exception {
  DFSHAAdmin tool = new DFSHAAdmin();
  tool.setConf(conf);
  assertEquals(0, 
      tool.run(new String[]{"-failover", "nn1", "nn2"}));
  waitForHAState(0, HAServiceState.STANDBY);
  waitForHAState(1, HAServiceState.ACTIVE);
  assertEquals(0,
      tool.run(new String[]{"-failover", "nn2", "nn1"}));
  waitForHAState(0, HAServiceState.ACTIVE);
  waitForHAState(1, HAServiceState.STANDBY);
}
 

import org.apache.hadoop.hdfs.tools.DFSHAAdmin; //导入依赖的package包/类
@Override
public void setConf(Configuration conf) {
  this.conf = DFSHAAdmin.addSecurityConfiguration(conf);
}