本文整理了Java中org.apache.hadoop.ha.ZKFailoverController类的一些代码示例，展示了ZKFailoverController类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZKFailoverController类的具体详情如下：
包路径：org.apache.hadoop.ha.ZKFailoverController
类名称：ZKFailoverController

ZKFailoverController介绍

暂无

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-common

private int doRun(String[] args)
  throws Exception {
 try {
  initZK();
 } catch (KeeperException ke) {
  LOG.error("Unable to start failover controller. Unable to connect "
      interactive = false;
     } else {
      badArg(args[i]);
    return formatZK(force, interactive);
    badArg(args[0]);
  initRPC();
  initHM();
  startRPC();
  mainLoop();
 } catch (Exception e) {
  LOG.error("The failover controller encounters runtime error: ", e);

代码示例来源：origin: org.apache.hadoop/hadoop-common

/**
 * Ensure that the local node is in a healthy state, and thus
 * eligible for graceful failover.
 * @throws ServiceFailedException if the node is unhealthy
 */
private synchronized void checkEligibleForFailover()
  throws ServiceFailedException {
 // Check health
 if (this.getLastHealthState() != State.SERVICE_HEALTHY) {
  throw new ServiceFailedException(
    localTarget + " is not currently healthy. " +
    "Cannot be failover target");
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
public void cedeActive(int millisToCede) throws IOException,
  AccessControlException {
 zkfc.checkRpcAdminAccess();
 zkfc.cedeActive(millisToCede);
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
public void gracefulFailover() throws IOException, AccessControlException {
 zkfc.checkRpcAdminAccess();
 zkfc.gracefulFailoverToYou();
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

private synchronized void fenceOldActive(byte[] data) {
 HAServiceTarget target = dataToTarget(data);
 
 try {
  doFence(target);
 } catch (Throwable t) {
  recordActiveAttempt(new ActiveAttemptRecord(false, "Unable to fence old active: " + StringUtils.stringifyException(t)));
  throw t;
 }
}

代码示例来源：origin: io.hops/hadoop-common

checkEligibleForFailover();
HAServiceTarget oldActive = getCurrentActive();
if (oldActive == null) {
ActiveAttemptRecord attempt = waitForActiveAttempt(timeout + 60000);

代码示例来源：origin: org.apache.hadoop/hadoop-common

checkEligibleForFailover();
HAServiceTarget oldActive = getCurrentActive();
if (oldActive == null) {
List<HAServiceTarget> otherNodes = getAllOtherNodes();
List<ZKFCProtocol> otherZkfcs = new ArrayList<ZKFCProtocol>(otherNodes.size());
  continue;
 otherZkfcs.add(cedeRemoteActive(remote, timeout));
otherZkfcs.add(cedeRemoteActive(activeNode, timeout));
ActiveAttemptRecord attempt = waitForActiveAttempt(timeout + 60000);

代码示例来源：origin: org.apache.hadoop/hadoop-common

if (millisToCede <= 0) {
   delayJoiningUntilNanotime = 0;
   recheckElectability();
   return;
  boolean needFence = false;
  try {
   localTarget.getProxy(conf, timeout).transitionToStandby(createReqInfo());
   LOG.info("Successfully ensured local node is in standby mode");
  } catch (IOException ioe) {
recheckElectability();

代码示例来源：origin: org.apache.hadoop/hadoop-common

HAServiceProtocolHelper.transitionToActive(localTarget.getProxy(
  conf, FailoverController.getRpcTimeoutToNewActive(conf)),
  createReqInfo());
String msg = "Successfully transitioned " + localTarget +
  " to active state";
LOG.info(msg);
serviceState = HAServiceState.ACTIVE;
recordActiveAttempt(new ActiveAttemptRecord(true, msg));
LOG.error(msg, t);
recordActiveAttempt(new ActiveAttemptRecord(false, msg + "\n" +
  StringUtils.stringifyException(t)));

代码示例来源：origin: org.apache.hadoop/hadoop-hdfs

@Override
protected void initRPC() throws IOException {
 super.initRPC();
 localNNTarget.setZkfcPort(rpcServer.getAddress().getPort());
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

private int formatZK(boolean force, boolean interactive)
  throws IOException, InterruptedException, KeeperException {
 if (elector.parentZNodeExists()) {
  if (!force && (!interactive || !confirmFormat())) {
   return ERR_CODE_FORMAT_DENIED;
  }
  
  try {
   elector.clearParentZNode();
  } catch (IOException e) {
   LOG.error("Unable to clear zk parent znode", e);
   return 1;
  }
 }
 
 elector.ensureParentZNode();
 return 0;
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

private synchronized void becomeStandby() {
 LOG.info("ZK Election indicated that " + localTarget +
   " should become standby");
 try {
  int timeout = FailoverController.getGracefulFenceTimeout(conf);
  localTarget.getProxy(conf, timeout).transitionToStandby(createReqInfo());
  LOG.info("Successfully transitioned " + localTarget +
    " to standby state");
 } catch (Exception e) {
  LOG.error("Couldn't transition " + localTarget + " to standby state",
    e);
  // TODO handle this. It's a likely case since we probably got fenced
  // at the same time.
 }
 serviceState = HAServiceState.STANDBY;
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

/**
 * @return an {@link HAServiceTarget} for the current active node
 * in the cluster, or null if no node is active.
 * @throws IOException if a ZK-related issue occurs
 * @throws InterruptedException if thread is interrupted 
 */
private HAServiceTarget getCurrentActive()
  throws IOException, InterruptedException {
 synchronized (elector) {
  synchronized (this) {
   byte[] activeData;
   try {
    activeData = elector.getActiveData();
   } catch (ActiveNotFoundException e) {
    return null;
   } catch (KeeperException ke) {
    throw new IOException(
      "Unexpected ZooKeeper issue fetching active node info", ke);
   }
   
   HAServiceTarget oldActive = dataToTarget(activeData);
   return oldActive;
  }
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

private synchronized void fenceOldActive(byte[] data) {
 HAServiceTarget target = dataToTarget(data);
 
 try {
  doFence(target);
 } catch (Throwable t) {
  recordActiveAttempt(new ActiveAttemptRecord(false, "Unable to fence old active: " + StringUtils.stringifyException(t)));
  Throwables.propagate(t);
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

checkEligibleForFailover();
HAServiceTarget oldActive = getCurrentActive();
if (oldActive == null) {
ActiveAttemptRecord attempt = waitForActiveAttempt(timeout + 60000);

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

@Override
public void gracefulFailover() throws IOException, AccessControlException {
 zkfc.checkRpcAdminAccess();
 zkfc.gracefulFailoverToYou();
}

代码示例来源：origin: io.hops/hadoop-common

if (millisToCede <= 0) {
   delayJoiningUntilNanotime = 0;
   recheckElectability();
   return;
  boolean needFence = false;
  try {
   localTarget.getProxy(conf, timeout).transitionToStandby(createReqInfo());
   LOG.info("Successfully ensured local node is in standby mode");
  } catch (IOException ioe) {
recheckElectability();

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

HAServiceProtocolHelper.transitionToActive(localTarget.getProxy(
  conf, FailoverController.getRpcTimeoutToNewActive(conf)),
  createReqInfo());
String msg = "Successfully transitioned " + localTarget +
  " to active state";
LOG.info(msg);
serviceState = HAServiceState.ACTIVE;
recordActiveAttempt(new ActiveAttemptRecord(true, msg));
LOG.fatal(msg, t);
recordActiveAttempt(new ActiveAttemptRecord(false, msg + "\n" +
  StringUtils.stringifyException(t)));

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

@Override
protected void initRPC() throws IOException {
 super.initRPC();
 localNNTarget.setZkfcPort(rpcServer.getAddress().getPort());
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

private int formatZK(boolean force, boolean interactive)
  throws IOException, InterruptedException {
 if (elector.parentZNodeExists()) {
  if (!force && (!interactive || !confirmFormat())) {
   return ERR_CODE_FORMAT_DENIED;
  }
  
  try {
   elector.clearParentZNode();
  } catch (IOException e) {
   LOG.error("Unable to clear zk parent znode", e);
   return 1;
  }
 }
 
 elector.ensureParentZNode();
 return 0;
}