[pulsar] branch branch-2.10 updated: Fixing get functions for output topic and serde classname (#14103)

[pe...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.10 by this push:
     new 48dd139  Fixing get functions for output topic and serde classname (#14103)
48dd139 is described below

commit 48dd1392aaec366cf930144ca43d38527aa36cd4
Author: Arnar <ar...@codedbearder.com>
AuthorDate: Fri Feb 25 09:10:53 2022 +0100

    Fixing get functions for output topic and serde classname (#14103)
    
    (cherry picked from commit b37ef081ec27e0a0b558dc239ecdd8fd1420210f)
---
 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 95afea7..2761862 100644
--- a/pulsar-functions/instance/src/main/python/contextimpl.py
+++ b/pulsar-functions/instance/src/main/python/contextimpl.py
@@ -139,10 +139,10 @@ class ContextImpl(pulsar.Context):
     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: