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

YarnHighAvailabilityServices.close介绍

[英]Flag marking this instance as shut down.
[中]将此实例标记为关闭的标记。

代码示例

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

@Test
public void testRepeatedClose() throws Exception {
  final Configuration flinkConfig = new Configuration();
  final YarnHighAvailabilityServices services = new YarnIntraNonHaMasterServices(flinkConfig, hadoopConfig);
  services.closeAndCleanupAllData();
  // this should not throw an exception
  services.close();
}

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

close();

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

@Test
public void testClosingReportsToLeader() throws Exception {
  final Configuration flinkConfig = new Configuration();
  try (YarnHighAvailabilityServices services = new YarnIntraNonHaMasterServices(flinkConfig, hadoopConfig)) {
    final LeaderElectionService elector = services.getResourceManagerLeaderElectionService();
    final LeaderRetrievalService retrieval = services.getResourceManagerLeaderRetriever();
    final LeaderContender contender = mockContender(elector);
    final LeaderRetrievalListener listener = mock(LeaderRetrievalListener.class);
    elector.start(contender);
    retrieval.start(listener);
    // wait until the contender has become the leader
    verify(listener, timeout(1000L).times(1)).notifyLeaderAddress(anyString(), any(UUID.class));
    // now we can close the election service
    services.close();
    verify(contender, timeout(1000L).times(1)).handleError(any(Exception.class));
  }
}

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

} catch (UnsupportedOperationException ignored) {}
services.close();

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

close();

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

close();