For externally managed functions, function worker should not do metri…

…cs management (apache#2775)
ccf19881030 · Oct 12, 2018 · 592737a · 592737a
1 parent 412859d
commit 592737a
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...tions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java b/...tions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java
@@ -651,6 +651,10 @@ public Map<String, FunctionRuntimeInfo> getFunctionRuntimeInfos() {
     }
 
     public void updateRates() {
+        if (runtimeFactory.externallyManaged()) {
+            // We don't do metrics management for externally managed functions
+            return;
+        }
         for (Entry<String, FunctionRuntimeInfo> entry : this.functionRuntimeInfoMap.entrySet()) {
             RuntimeSpawner functionRuntimeSpawner = entry.getValue().getRuntimeSpawner();
             if (functionRuntimeSpawner != null) {