Skip to content

Commit bb412cd

Browse files
committed
Do not rely on high-availability cm label
1 parent 417509f commit bb412cd

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -306,15 +306,11 @@ private static boolean isKubernetesHaMetadataAvailable(
306306
String clusterId = conf.get(KubernetesConfigOptions.CLUSTER_ID);
307307
String namespace = conf.get(KubernetesConfigOptions.NAMESPACE);
308308

309-
var haConfigMapLabels =
310-
KubernetesUtils.getConfigMapLabels(
311-
clusterId, Constants.LABEL_CONFIGMAP_TYPE_HIGH_AVAILABILITY);
312-
313309
var configMaps =
314310
kubernetesClient
315311
.configMaps()
316312
.inNamespace(namespace)
317-
.withLabels(haConfigMapLabels)
313+
.withLabels(KubernetesUtils.getCommonLabels(clusterId))
318314
.list()
319315
.getItems();
320316

0 commit comments

Comments
 (0)