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

WebMonitor介绍

[英]Interface for web monitors. Defines life-cycle methods and properties.
[中]

代码示例

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

highAvailabilityServices,
  metricRegistry,
  webMonitor == null ? Option.empty() : Option.apply(webMonitor.getRestAddress()),
  new Some<>(JobMaster.JOB_MANAGER_NAME),
  Option.<String>empty(),
  getArchivistClass())._1();
final String webMonitorURL = webMonitor == null ? null : webMonitor.getRestAddress();
    webMonitor.stop();
  } catch (Throwable ignored) {
    LOG.warn("Failed to stop the web frontend", t);
  webMonitor.stop();
} catch (Throwable t) {
  LOG.error("Failed to stop the web frontend", t);

代码示例来源：origin: com.alibaba.blink/flink-runtime

monitor.start();

代码示例来源：origin: org.apache.flink/flink-runtime-web_2.10

@Override
  public void handleError(Exception exception) {
    LOG.error("Received error from LeaderRetrievalService.", exception);

    try {
      // stop associated webMonitor
      webMonitor.stop();
    }
    catch (Exception e) {
      LOG.error("Error while stopping the web server due to a LeaderRetrievalService error.", e);
    }
  }
}

代码示例来源：origin: com.alibaba.blink/flink-test-utils

private void startLegacyMiniCluster() throws Exception {
  final Configuration configuration = new Configuration(miniClusterResourceConfiguration.getConfiguration());
  configuration.setInteger(ConfigConstants.LOCAL_NUMBER_TASK_MANAGER, miniClusterResourceConfiguration.getNumberTaskManagers());
  configuration.setInteger(TaskManagerOptions.NUM_TASK_SLOTS, miniClusterResourceConfiguration.getNumberSlotsPerTaskManager());
  configuration.setString(CoreOptions.TMP_DIRS, temporaryFolder.newFolder().getAbsolutePath());
  final LocalFlinkMiniCluster flinkMiniCluster = TestBaseUtils.startCluster(
    configuration,
    !enableClusterClient); // the cluster client only works if separate actor systems are used
  jobExecutorService = flinkMiniCluster;
  if (enableClusterClient) {
    clusterClient = new StandaloneClusterClient(configuration, flinkMiniCluster.highAvailabilityServices(), true);
  }
  Configuration restClientConfig = new Configuration();
  restClientConfig.setInteger(JobManagerOptions.PORT, flinkMiniCluster.getLeaderRPCPort());
  this.restClusterClientConfig = new UnmodifiableConfiguration(restClientConfig);
  if (flinkMiniCluster.webMonitor().isDefined()) {
    webUIPort = flinkMiniCluster.webMonitor().get().getServerPort();
  }
}

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

monitor.start();

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

highAvailabilityServices,
  metricRegistry,
  webMonitor == null ? Option.empty() : Option.apply(webMonitor.getRestAddress()),
  new Some<>(JobMaster.JOB_MANAGER_NAME),
  Option.<String>empty(),
  getArchivistClass())._1();
final String webMonitorURL = webMonitor == null ? null : webMonitor.getRestAddress();
    webMonitor.stop();
  } catch (Throwable ignored) {
    LOG.warn("Failed to stop the web frontend", t);
  webMonitor.stop();
} catch (Throwable t) {
  LOG.error("Failed to stop the web frontend", t);

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

monitor.start();

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

highAvailabilityServices,
  metricRegistry,
  webMonitor == null ? Option.empty() : Option.apply(webMonitor.getRestAddress()),
  new Some<>(JobMaster.JOB_MANAGER_NAME),
  Option.<String>empty(),
  getArchivistClass())._1();
final String webMonitorURL = webMonitor == null ? null : webMonitor.getRestAddress();
    webMonitor.stop();
  } catch (Throwable ignored) {
    LOG.warn("Failed to stop the web frontend", t);
  webMonitor.stop();
} catch (Throwable t) {
  LOG.error("Failed to stop the web frontend", t);

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

monitor.start(jobManagerAkkaURL);