import org.apache.hadoop.yarn.server.resourcemanager.RMFatalEvent; //导入依赖的package包/类
@SuppressWarnings("unchecked")
/**
 * This method is called to notify the ResourceManager that the store
 * operation has failed.
 * @param failureCause the exception due to which the operation failed
 */
protected void notifyStoreOperationFailed(Exception failureCause) {
  if (failureCause instanceof StoreFencedException) {
    updateFencedState();
    Thread standByTransitionThread =
        new Thread(new StandByTransitionThread());
    standByTransitionThread.setName("StandByTransitionThread Handler");
    standByTransitionThread.start();
  } else {
    rmDispatcher.getEventHandler().handle(
      new RMFatalEvent(RMFatalEventType.STATE_STORE_OP_FAILED, failureCause));
  }
}
 

import org.apache.hadoop.yarn.server.resourcemanager.RMFatalEvent; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private boolean notifyStoreOperationFailedInternal(
    Exception failureCause) {
  boolean isFenced = false;
  LOG.error("State store operation failed ", failureCause);
  if (HAUtil.isHAEnabled(getConfig())) {
    LOG.warn("State-store fenced ! Transitioning RM to standby");
    isFenced = true;
    Thread standByTransitionThread =
        new Thread(new StandByTransitionThread());
    standByTransitionThread.setName("StandByTransitionThread Handler");
    standByTransitionThread.start();
  } else if (YarnConfiguration.shouldRMFailFast(getConfig())) {
    LOG.fatal("Fail RM now due to state-store error!");
    rmDispatcher.getEventHandler().handle(
        new RMFatalEvent(RMFatalEventType.STATE_STORE_OP_FAILED,
            failureCause));
  } else {
    LOG.warn("Skip the state-store error.");
  }
  return isFenced;
}
 

import org.apache.hadoop.yarn.server.resourcemanager.RMFatalEvent; //导入依赖的package包/类
@SuppressWarnings("unchecked")
/**
 * This method is called to notify the ResourceManager that the store
 * operation has failed.
 * @param failureCause the exception due to which the operation failed
 */
protected void notifyStoreOperationFailed(Exception failureCause) {
  if (failureCause instanceof StoreFencedException) {
    Thread standByTransitionThread =
        new Thread(new StandByTransitionThread());
    standByTransitionThread.setName("StandByTransitionThread Handler");
    standByTransitionThread.start();
  } else {
    rmDispatcher.getEventHandler().handle(
      new RMFatalEvent(RMFatalEventType.STATE_STORE_OP_FAILED, failureCause));
  }
}
 

import org.apache.hadoop.yarn.server.resourcemanager.RMFatalEvent; //导入依赖的package包/类
@SuppressWarnings("unchecked")
/**
 * This method is called to notify the ResourceManager that the store
 * operation has failed.
 * @param failureCause the exception due to which the operation failed
 */
protected void notifyStoreOperationFailed(Exception failureCause) {
  RMFatalEventType type;
  if (failureCause instanceof StoreFencedException) {
    type = RMFatalEventType.STATE_STORE_FENCED;
  } else {
    type = RMFatalEventType.STATE_STORE_OP_FAILED;
  }
  rmDispatcher.getEventHandler().handle(new RMFatalEvent(type, failureCause));
}