Java 类org.apache.hadoop.hdfs.protocol.RollingUpgradeException 实例源码

项目：hadoop 文件：FSNamesystem.java

void checkRollingUpgrade(String action) throws RollingUpgradeException {
  if (isRollingUpgrade()) {
    throw new RollingUpgradeException("Failed to " + action
        + " since a rolling upgrade is already in progress."
        + " Existing rolling upgrade info:\n" + rollingUpgradeInfo);
  }
}

项目：aliyun-oss-hadoop-fs 文件：FSNamesystem.java

void checkRollingUpgrade(String action) throws RollingUpgradeException {
  if (isRollingUpgrade()) {
    throw new RollingUpgradeException("Failed to " + action
        + " since a rolling upgrade is already in progress."
        + " Existing rolling upgrade info:\n" + rollingUpgradeInfo);
  }
}

项目：big-c 文件：FSNamesystem.java

void checkRollingUpgrade(String action) throws RollingUpgradeException {
  if (isRollingUpgrade()) {
    throw new RollingUpgradeException("Failed to " + action
        + " since a rolling upgrade is already in progress."
        + " Existing rolling upgrade info:\n" + rollingUpgradeInfo);
  }
}

项目：hadoop-2.6.0-cdh5.4.3 文件：FSNamesystem.java

void checkRollingUpgrade(String action) throws RollingUpgradeException {
  if (isRollingUpgrade()) {
    throw new RollingUpgradeException("Failed to " + action
        + " since a rolling upgrade is already in progress."
        + " Existing rolling upgrade info:\n" + rollingUpgradeInfo);
  }
}

项目：FlexMap 文件：FSNamesystem.java

void checkRollingUpgrade(String action) throws RollingUpgradeException {
  if (isRollingUpgrade()) {
    throw new RollingUpgradeException("Failed to " + action
        + " since a rolling upgrade is already in progress."
        + " Existing rolling upgrade info:\n" + rollingUpgradeInfo);
  }
}

项目：hadoop-on-lustre2 文件：FSNamesystem.java

void checkRollingUpgrade(String action) throws RollingUpgradeException {
  if (isRollingUpgrade()) {
    throw new RollingUpgradeException("Failed to " + action
        + " since a rolling upgrade is already in progress."
        + " Existing rolling upgrade info:\n" + rollingUpgradeInfo);
  }
}

项目：hadoop-on-lustre2 文件：FSNamesystem.java

RollingUpgradeInfo finalizeRollingUpgradeInternal(long finalizeTime)
    throws RollingUpgradeException {
  if (!isRollingUpgrade()) {
    throw new RollingUpgradeException(
        "Failed to finalize rolling upgrade since there is no rolling upgrade in progress.");
  }

  final long startTime = rollingUpgradeInfo.getStartTime();
  rollingUpgradeInfo = null;
  return new RollingUpgradeInfo(blockPoolId, false, startTime, finalizeTime);
}

项目：hadoop 文件：FSNamesystem.java

RollingUpgradeInfo finalizeRollingUpgradeInternal(long finalizeTime)
    throws RollingUpgradeException {
  final long startTime = rollingUpgradeInfo.getStartTime();
  rollingUpgradeInfo = null;
  return new RollingUpgradeInfo(blockPoolId, false, startTime, finalizeTime);
}

项目：big-c 文件：FSNamesystem.java

RollingUpgradeInfo finalizeRollingUpgradeInternal(long finalizeTime)
    throws RollingUpgradeException {
  final long startTime = rollingUpgradeInfo.getStartTime();
  rollingUpgradeInfo = null;
  return new RollingUpgradeInfo(blockPoolId, false, startTime, finalizeTime);
}

项目：FlexMap 文件：FSNamesystem.java

RollingUpgradeInfo finalizeRollingUpgradeInternal(long finalizeTime)
    throws RollingUpgradeException {
  final long startTime = rollingUpgradeInfo.getStartTime();
  rollingUpgradeInfo = null;
  return new RollingUpgradeInfo(blockPoolId, false, startTime, finalizeTime);
}