pulsar-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sanjee...@apache.org
Subject [pulsar] branch master updated: Add labels to function statefulsets and services (#4038)
Date Sat, 13 Apr 2019 06:03:51 GMT
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 de6bc11  Add labels to function statefulsets and services (#4038)
de6bc11 is described below

commit de6bc1177a251066c7b148c3fa98a21c27f51417
Author: Sanjeev Kulkarni <sanjeevrk@gmail.com>
AuthorDate: Fri Apr 12 23:03:45 2019 -0700

    Add labels to function statefulsets and services (#4038)
    
    * Add labels to function statefulsets and services. Also upgraded the kubernetes client
version to the latest
    
    * Fix unittests
    
    * Reverted back the kubernertes library upgrade since shading was causing issues
---
 .../java/org/apache/pulsar/functions/runtime/KubernetesRuntime.java     | 2 ++
 1 file changed, 2 insertions(+)

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 3d11858..6dbb0d3 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
@@ -417,6 +417,7 @@ public class KubernetesRuntime implements Runtime {
         // setup stateful set metadata
         final V1ObjectMeta objectMeta = new V1ObjectMeta();
         objectMeta.name(jobName);
+        objectMeta.setLabels(getLabels(instanceConfig.getFunctionDetails()));
         service.metadata(objectMeta);
 
         // create the stateful set spec
@@ -798,6 +799,7 @@ public class KubernetesRuntime implements Runtime {
         // setup stateful set metadata
         final V1ObjectMeta objectMeta = new V1ObjectMeta();
         objectMeta.name(jobName);
+        objectMeta.setLabels(getLabels(instanceConfig.getFunctionDetails()));
         statefulSet.metadata(objectMeta);
 
         // create the stateful set spec


Mime
View raw message