MAPREDUCE服务 MRS-如何处理非static的KafkaPartitioner类对象构造FlinkKafkaProducer010运行时报错:问题

时间:2024-06-13 09:38:25

问题

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-lts-mrs/mrs_07_050051.html