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

ZKFailoverController.createReqInfo介绍

暂无

代码示例

代码示例来源：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

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

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

HAServiceProtocolHelper.transitionToActive(localTarget.getProxy(
  conf, FailoverController.getRpcTimeoutToNewActive(conf)),
  createReqInfo());
String msg = "Successfully transitioned " + localTarget +
  " to active state";

代码示例来源：origin: io.hops/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: ch.cern.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: com.github.jiayuhan-it/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: io.hops/hadoop-common

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

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

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

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

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

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

HAServiceProtocolHelper.transitionToActive(localTarget.getProxy(
  conf, FailoverController.getRpcTimeoutToNewActive(conf)),
  createReqInfo());
String msg = "Successfully transitioned " + localTarget +
  " to active state";

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

HAServiceProtocolHelper.transitionToActive(localTarget.getProxy(
  conf, FailoverController.getRpcTimeoutToNewActive(conf)),
  createReqInfo());
String msg = "Successfully transitioned " + localTarget +
  " to active state";

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

HAServiceProtocolHelper.transitionToActive(localTarget.getProxy(
  conf, FailoverController.getRpcTimeoutToNewActive(conf)),
  createReqInfo());
String msg = "Successfully transitioned " + localTarget +
  " to active state";

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

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

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

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: io.prestosql.hadoop/hadoop-apache

HAServiceProtocolHelper.transitionToActive(localTarget.getProxy(
  conf, FailoverController.getRpcTimeoutToNewActive(conf)),
  createReqInfo());
String msg = "Successfully transitioned " + localTarget +
  " to active state";