Fixed Kubernetes runtime bug (apache#3123)

yciabaud · Dec 5, 2018 · e5a9ec3 · e5a9ec3
1 parent 032df08
commit e5a9ec3
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...unctions/runtime/src/main/java/org/apache/pulsar/functions/runtime/KubernetesRuntime.java b/...unctions/runtime/src/main/java/org/apache/pulsar/functions/runtime/KubernetesRuntime.java
@@ -524,10 +524,9 @@ private Map<String, String> getPrometheusAnnotations() {
 
     private Map<String, String> getLabels(Function.FunctionDetails functionDetails) {
         final Map<String, String> labels = new HashMap<>();
-        labels.put("namespace", String.format("%s/%s",functionDetails.getTenant(), functionDetails.getNamespace()));
+        labels.put("namespace", functionDetails.getNamespace());
         labels.put("tenant", functionDetails.getTenant());
-        labels.put("function", String.format("%s/%s/%s", functionDetails.getTenant(),
-                functionDetails.getNamespace(), functionDetails.getName()));
+        labels.put("function", functionDetails.getName());
         if (customLabels != null && !customLabels.isEmpty()) {
             labels.putAll(customLabels);
         }