[FLINK-37272][python] Minor fix of FlinkAvroBufferWrapper

dianfu · dianfu · commit 21e30869d65d · 2025-02-11T12:02:35.000+08:00
diff --git a/flink-python/pyflink/fn_execution/formats/avro.py b/flink-python/pyflink/fn_execution/formats/avro.py
@@ -44,7 +44,7 @@ def read(self, n=1):
         return self._stream.read(n)
 
     def write(self, data):
-        return self._stream.write(data)
+        return self._stream.write(bytes(data))
 
 
 class FlinkAvroDecoder(BinaryDecoder):
