Brad Murry
08/13/2024, 10:10 PMCaused by: org.apache.flink.streaming.runtime.tasks.StreamTaskException: Could not serialize object for key serializedUDF.
And I believe it is caused by the inner class Py4J requires to register as an interface callback.
eg: this bit-
class DictElementConverter:
class Java:
implements = ['org.apache.flink.connector.base.sink.writer.ElementConverter',
'java.io.Serializable']
Brad Murry
08/13/2024, 10:11 PMAttributeError: 'DictElementConverter' object has no attribute '_get_object_id'
D. Draco O'Brien
08/14/2024, 7:46 AM