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 592737a For externally managed functions, function worker should not do metrics management (#2775) 592737a is described below commit 592737a201ee848881c5fa84b35c927e7cad75a2 Author: Sanjeev Kulkarni <sanjee...@gmail.com> AuthorDate: Thu Oct 11 20:07:57 2018 -0700 For externally managed functions, function worker should not do metrics management (#2775) --- .../org/apache/pulsar/functions/worker/FunctionRuntimeManager.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java index 2514ff6..aa843ca 100644 --- a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java +++ b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java @@ -651,6 +651,10 @@ public class FunctionRuntimeManager implements AutoCloseable{ } 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) {