class KubernetesJobManagerParameters extends AbstractKubernetesParameters {

	@Override
	public Map<String, String> getAnnotations() {
		return flinkConfig.getOptional(KubernetesConfigOptions.JOB_MANAGER_ANNOTATIONS).orElse(Collections.emptyMap());
	}

	public  KubernetesJobManagerParameters(Configuration flinkConfig, ClusterSpecification clusterSpecification);

}