class KubernetesJobManagerParameters extends AbstractKubernetesParameters {

	@Override
	public Map<String, String> getLabels() {
		final Map<String, String> labels = new HashMap<>();
		labels.putAll(flinkConfig.getOptional(KubernetesConfigOptions.JOB_MANAGER_LABELS).orElse(Collections.emptyMap()));
		labels.putAll(getCommonLabels());
		labels.put(Constants.LABEL_COMPONENT_KEY, Constants.LABEL_COMPONENT_JOB_MANAGER);
		return Collections.unmodifiableMap(labels);
	}

	public  KubernetesJobManagerParameters(Configuration flinkConfig, ClusterSpecification clusterSpecification);

}