We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 866e1a9 commit 979fe75Copy full SHA for 979fe75
flink-python/pyflink/fn_execution/formats/avro.py
@@ -44,7 +44,7 @@ def read(self, n=1):
44
return self._stream.read(n)
45
46
def write(self, data):
47
- return self._stream.write(data)
+ return self._stream.write(bytes(data))
48
49
50
class FlinkAvroDecoder(BinaryDecoder):
0 commit comments