[Functions] Prevent NPE while stopping a non started Pulsar LogAppend…

…er (apache#12643)
mrb101 · Nov 5, 2021 · f65f272 · f65f272
1 parent 176f75a
commit f65f272
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/...ar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/LogAppender.java b/...ar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/LogAppender.java
@@ -108,16 +108,18 @@ public void start() {
                     .property("function", fqn)
                     .create();
         } catch (Exception e) {
-            throw new RuntimeException("Error starting LogTopic Producer", e);
+            throw new RuntimeException("Error starting LogTopic Producer for function " + fqn, e);
         }
         this.state = State.STARTED;
     }
 
     @Override
     public void stop() {
         this.state = State.STOPPING;
-        producer.closeAsync();
-        producer = null;
+        if (producer != null) {
+            producer.closeAsync();
+            producer = null;
+        }
         this.state = State.STOPPED;
     }