public class KubernetesUtils extends Object
Modifier and Type | Class and Description |
---|---|
static class |
KubernetesUtils.ClusterComponent
Cluster components.
|
Modifier and Type | Method and Description |
---|---|
static void |
checkAndUpdatePortConfigOption(Configuration flinkConfig,
ConfigOption<String> port,
int fallbackPort)
Check whether the port config option is a fixed port.
|
static List<File> |
checkJarFileForApplicationMode(Configuration configuration) |
static String |
getCommonStartCommand(Configuration flinkConfig,
KubernetesUtils.ClusterComponent mode,
String jvmMemOpts,
String configDirectory,
String logDirectory,
boolean hasLogback,
boolean hasLog4j,
String mainClass,
String mainArgs) |
static String |
getDeploymentName(String clusterId)
Generate name of the Deployment.
|
static io.fabric8.kubernetes.api.model.ResourceRequirements |
getResourceRequirements(int mem,
double cpu,
Map<String,Long> externalResources)
Get resource requirements from memory and cpu.
|
static Map<String,String> |
getTaskManagerLabels(String clusterId)
Get task manager labels for the current Flink cluster.
|
static Integer |
parsePort(Configuration flinkConfig,
ConfigOption<String> port)
Parse a valid port for the config option.
|
public static void checkAndUpdatePortConfigOption(Configuration flinkConfig, ConfigOption<String> port, int fallbackPort)
flinkConfig
- flink configurationport
- config option need to be checkedfallbackPort
- the fallback port that will be set to the configurationpublic static Integer parsePort(Configuration flinkConfig, ConfigOption<String> port)
flinkConfig
- flink configport
- port config optionpublic static String getDeploymentName(String clusterId)
public static Map<String,String> getTaskManagerLabels(String clusterId)
public static io.fabric8.kubernetes.api.model.ResourceRequirements getResourceRequirements(int mem, double cpu, Map<String,Long> externalResources)
mem
- Memory in mb.cpu
- cpu.externalResources
- external resourcespublic static String getCommonStartCommand(Configuration flinkConfig, KubernetesUtils.ClusterComponent mode, String jvmMemOpts, String configDirectory, String logDirectory, boolean hasLogback, boolean hasLog4j, String mainClass, @Nullable String mainArgs)
public static List<File> checkJarFileForApplicationMode(Configuration configuration)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.