MAPREDUCE服务 MRS-为什么非static的KafkaPartitioner类对象去构造FlinkKafkaProducer010,运行时会报错?:问题

时间:2024-06-19 14:14:18

问题

Flink内核升级到1.3.0之后,当kafka调用带有非static的KafkaPartitioner类对象为参数的FlinkKafkaProducer010去构造函数时,运行时会报错。

报错内容如下:

org.apache.flink.api.common.InvalidProgramException: The implementation of the FlinkKafkaPartitioner is not serializable. The object probably contains or references non serializable fields.
support.huaweicloud.com/devg-mrs/mrs_06_0421.html