From 7ecf51ed694cb8b99c6288dafb62d879a6605456 Mon Sep 17 00:00:00 2001 From: Arnar Date: Fri, 25 Feb 2022 09:10:53 +0100 Subject: [PATCH] Fixing get functions for output topic and serde classname (#14103) (cherry picked from commit b37ef081ec27e0a0b558dc239ecdd8fd1420210f) (cherry picked from commit 70462663b4508083bc2b49e304c4a899b9c24f46) --- pulsar-functions/instance/src/main/python/contextimpl.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pulsar-functions/instance/src/main/python/contextimpl.py b/pulsar-functions/instance/src/main/python/contextimpl.py index 95afea73eaca3..27618626cf77e 100644 --- a/pulsar-functions/instance/src/main/python/contextimpl.py +++ b/pulsar-functions/instance/src/main/python/contextimpl.py @@ -139,10 +139,10 @@ def get_input_topics(self): return list(self.instance_config.function_details.source.inputSpecs.keys()) def get_output_topic(self): - return self.instance_config.function_details.output + return self.instance_config.function_details.sink.topic def get_output_serde_class_name(self): - return self.instance_config.function_details.outputSerdeClassName + return self.instance_config.function_details.sink.serDeClassName def callback_wrapper(self, callback, topic, message_id, result, msg): if result != pulsar.Result.Ok: