add labels

apache · Sep 17, 2023 · 30602ba · 30602ba
1 parent 0bac2bf
commit 30602ba
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...plugin/flink/client/shims/deployment/FlinkDeploymentOperatorClusterDescriptorAdapter.java b/...plugin/flink/client/shims/deployment/FlinkDeploymentOperatorClusterDescriptorAdapter.java
@@ -38,7 +38,9 @@
 import org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.client.dsl.NonNamespaceOperation;
 
 import java.io.Closeable;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 import java.util.Objects;
 import java.util.stream.Collectors;
 
@@ -210,6 +212,9 @@ public FlinkDeployment getFlinkDeployment(String name, String namespace) {
     ObjectMeta metadata = new ObjectMeta();
     metadata.setName(name);
     metadata.setNamespace(namespace);
+    Map<String, String> labels = new HashMap<>();
+    labels.put("from-app", "linkis");
+    metadata.setLabels(labels);
     flinkDeployment.setMetadata(metadata);
     return flinkDeployment;
   }