[pulsar] branch master updated: Fixed Kubernetes runtime bug (#3123)

[sa...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

sanjeevrk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new e5a9ec3  Fixed Kubernetes runtime bug (#3123)
e5a9ec3 is described below

commit e5a9ec3a7c43a2b521c63018aaf99197a8c32162
Author: Sanjeev Kulkarni <sa...@gmail.com>
AuthorDate: Tue Dec 4 16:31:46 2018 -0800

    Fixed Kubernetes runtime bug (#3123)
---
 .../java/org/apache/pulsar/functions/runtime/KubernetesRuntime.java  | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/KubernetesRuntime.java b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/KubernetesRuntime.java
index cd83e69..9ae3bfc 100644
--- a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/KubernetesRuntime.java
+++ b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/KubernetesRuntime.java
@@ -524,10 +524,9 @@ class KubernetesRuntime implements Runtime {
 
     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);
         }