Check if javaInstance is created in the first place before invocing c…

…lose (#1688)
apache · May 1, 2018 · 600b55d · 600b55d
1 parent fb7198a
commit 600b55d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...ons/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java b/...ons/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java
@@ -348,7 +348,9 @@ private void sendOutputMessage(Record srcRecord,
     @Override
     public void close() {
         processor.close();
-        javaInstance.close();
+        if (null != javaInstance) {
+            javaInstance.close();
+        }
 
         // kill the state table
         if (null != stateTable) {