The error I'm running into is: `Caused by: org.apa...
# troubleshooting
b
The error I'm running into is:
Caused 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-
Copy code
class DictElementConverter:
    class Java:
        implements = ['org.apache.flink.connector.base.sink.writer.ElementConverter',
                      'java.io.Serializable']
Without setting that inner class, I get the following error:
Copy code
AttributeError: 'DictElementConverter' object has no attribute '_get_object_id'
d
What happens if you subclass DictElementConverter itself and have it implement serializable? Does the first error go away?