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

YarnIntraNonHaMasterServices.exit介绍

暂无

代码示例

代码示例来源：origin: apache/flink

@Override
public LeaderRetrievalService getJobManagerLeaderRetriever(JobID jobID, String defaultJobManagerAddress) {
  enter();
  try {
    throw new UnsupportedOperationException("needs refactoring to accept default address");
  }
  finally {
    exit();
  }
}

代码示例来源：origin: apache/flink

@Override
public LeaderRetrievalService getWebMonitorLeaderRetriever() {
  enter();
  try {
    throw new UnsupportedOperationException();
  }
  finally {
    exit();
  }
}

代码示例来源：origin: apache/flink

@Override
public LeaderElectionService getResourceManagerLeaderElectionService() {
  enter();
  try {
    return resourceManagerLeaderElectionService;
  }
  finally {
    exit();
  }
}

代码示例来源：origin: apache/flink

@Override
public LeaderElectionService getJobManagerLeaderElectionService(JobID jobID) {
  enter();
  try {
    throw new UnsupportedOperationException("needs refactoring to accept default address");
  }
  finally {
    exit();
  }
}

代码示例来源：origin: apache/flink

@Override
public LeaderElectionService getWebMonitorLeaderElectionService() {
  enter();
  try {
    throw new UnsupportedOperationException();
  }
  finally {
    exit();
  }
}

代码示例来源：origin: apache/flink

@Override
public LeaderRetrievalService getJobManagerLeaderRetriever(JobID jobID) {
  enter();
  try {
    throw new UnsupportedOperationException("needs refactoring to accept default address");
  }
  finally {
    exit();
  }
}

代码示例来源：origin: apache/flink

@Override
public LeaderElectionService getDispatcherLeaderElectionService() {
  enter();
  try {
    return dispatcherLeaderElectionService;
  } finally {
    exit();
  }
}

代码示例来源：origin: apache/flink

@Override
public LeaderRetrievalService getResourceManagerLeaderRetriever() {
  enter();
  try {
    return resourceManagerLeaderElectionService.createLeaderRetrievalService();
  }
  finally {
    exit();
  }
}

代码示例来源：origin: apache/flink

@Override
public LeaderRetrievalService getDispatcherLeaderRetriever() {
  enter();
  try {
    return dispatcherLeaderElectionService.createLeaderRetrievalService();
  } finally {
    exit();
  }
}

代码示例来源：origin: apache/flink

@Override
  public void close() throws Exception {
    if (enterUnlessClosed()) {
      try {
        try {
          // this class' own cleanup logic
          resourceManagerLeaderElectionService.shutdown();
          dispatcher.shutdownNow();
        }
        finally {
          // in any case must we call the parent cleanup logic
          super.close();
        }
      }
      finally {
        exit();
      }
    }
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn

@Override
public LeaderElectionService getDispatcherLeaderElectionService() {
  enter();
  try {
    return dispatcherLeaderElectionService;
  } finally {
    exit();
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn

@Override
public LeaderRetrievalService getJobManagerLeaderRetriever(JobID jobID, String defaultJobManagerAddress) {
  enter();
  try {
    throw new UnsupportedOperationException("needs refactoring to accept default address");
  }
  finally {
    exit();
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn

@Override
public LeaderRetrievalService getWebMonitorLeaderRetriever() {
  enter();
  try {
    throw new UnsupportedOperationException();
  }
  finally {
    exit();
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn

@Override
public LeaderRetrievalService getJobManagerLeaderRetriever(JobID jobID) {
  enter();
  try {
    throw new UnsupportedOperationException("needs refactoring to accept default address");
  }
  finally {
    exit();
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn_2.11

@Override
public LeaderElectionService getDispatcherLeaderElectionService() {
  enter();
  try {
    return dispatcherLeaderElectionService;
  } finally {
    exit();
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn

@Override
public LeaderElectionService getResourceManagerLeaderElectionService() {
  enter();
  try {
    return resourceManagerLeaderElectionService;
  }
  finally {
    exit();
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn

@Override
public LeaderElectionService getWebMonitorLeaderElectionService() {
  enter();
  try {
    throw new UnsupportedOperationException();
  }
  finally {
    exit();
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn_2.11

@Override
public LeaderElectionService getWebMonitorLeaderElectionService() {
  enter();
  try {
    throw new UnsupportedOperationException();
  }
  finally {
    exit();
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn_2.11

@Override
public LeaderRetrievalService getJobManagerLeaderRetriever(JobID jobID) {
  enter();
  try {
    throw new UnsupportedOperationException("needs refactoring to accept default address");
  }
  finally {
    exit();
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn_2.11

@Override
public LeaderElectionService getJobManagerLeaderElectionService(JobID jobID) {
  enter();
  try {
    throw new UnsupportedOperationException("needs refactoring to accept default address");
  }
  finally {
    exit();
  }
}