Handle case where function produces some output but no output topic g…

…iven (apache#2941)
nicky1 · Nov 6, 2018 · be0fe35 · be0fe35
1 parent 76b46a5
commit be0fe35
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pulsar-functions/instance/src/main/python/python_instance.py b/pulsar-functions/instance/src/main/python/python_instance.py
@@ -272,7 +272,8 @@ def done_producing(self, consumer, orig_message, result, sent_message):
       consumer.acknowledge(orig_message)
 
   def process_result(self, output, msg):
-    if output is not None:
+    if output is not None and self.instance_config.function_details.sink.topic != None and \
+            len(self.instance_config.function_details.sink.topic) > 0:
       if self.output_serde is None:
         self.setup_output_serde()
       if self.producer is None: