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 <sanjee...@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); }