public class MesosJobClusterEntrypoint
extends org.apache.flink.runtime.entrypoint.JobClusterEntrypoint
| Constructor and Description |
|---|
MesosJobClusterEntrypoint(org.apache.flink.configuration.Configuration config,
org.apache.flink.configuration.Configuration dynamicProperties) |
| Modifier and Type | Method and Description |
|---|---|
protected org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponentFactory<?> |
createDispatcherResourceManagerComponentFactory(org.apache.flink.configuration.Configuration configuration) |
protected void |
initializeServices(org.apache.flink.configuration.Configuration config) |
static void |
main(String[] args) |
protected CompletableFuture<Void> |
stopClusterServices(boolean cleanupHaData) |
createSerializableExecutionGraphStorecloseAsync, createHaServices, createHeartbeatServices, createMetricRegistry, getRPCPortRange, getTerminationFuture, installSecurityContext, loadConfiguration, onFatalError, parseArguments, runClusterEntrypoint, startClusterpublic MesosJobClusterEntrypoint(org.apache.flink.configuration.Configuration config,
org.apache.flink.configuration.Configuration dynamicProperties)
protected void initializeServices(org.apache.flink.configuration.Configuration config)
throws Exception
initializeServices in class org.apache.flink.runtime.entrypoint.ClusterEntrypointExceptionprotected CompletableFuture<Void> stopClusterServices(boolean cleanupHaData)
stopClusterServices in class org.apache.flink.runtime.entrypoint.ClusterEntrypointprotected org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponentFactory<?> createDispatcherResourceManagerComponentFactory(org.apache.flink.configuration.Configuration configuration)
createDispatcherResourceManagerComponentFactory in class org.apache.flink.runtime.entrypoint.ClusterEntrypointpublic static void main(String[] args)
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.