fixing python function example custom_object_function.py (apache#4946)

ouyanghuangzheng · Aug 18, 2019 · 33441ea · 33441ea
1 parent 1691cc8
commit 33441ea
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pulsar-functions/python-examples/custom_object_function.py b/pulsar-functions/python-examples/custom_object_function.py
@@ -31,10 +31,10 @@ def __init__(self):
     pass
 
   def serialize(self, object):
-    return "%d,%d" % (object.a, object.b)
+    return ("%d,%d" % (object.a, object.b)).encode('utf-8')
 
   def deserialize(self, input_bytes):
-    split = str(input_bytes).split(',')
+    split = str(input_bytes.decode()).split(',')
     retval = MyObject()
     retval.a = int(split[0])
     retval.b = int(split[1])