Apache Flink序列化POJO类时抛出KryoException异常问题求助

问题根因 #

你的报错核心是Java 9+引入的不可变集合与Flink 1.14内置的低版本Kryo序列化器不兼容：

• 你构造Species对象时，abilities字段大概率用了List.of()等方法返回的JDK内置不可变List实例
• Flink 1.14内置的Kryo版本为4.0.x，默认的集合序列化器反序列化时会先创建空集合实例，再调用add()方法填充元素，而不可变集合不支持add()操作，直接抛出UnsupportedOperationException
• 你之前添加的enableForceKryo配置反而强制所有类型走Kryo序列化，绕开了Flink原生支持不可变集合的POJO序列化器，导致问题没有解决

解决方案 #

你可以任选以下一种方案修复：

方案1：业务代码中使用可变集合（改造成本最低） #

构造Species对象时，将不可变List转换为可变ArrayList再赋值，不需要修改任何Flink配置即可兼容原有序列化逻辑：

// 错误写法
Species species = new Species("cat", List.of("run", "jump"));
// 正确写法
Species species = new Species("cat", new ArrayList<>(List.of("run", "jump")));

方案2：关闭强制Kryo序列化，使用Flink原生POJO序列化 #

去掉你添加的enableForceKryo配置，Flink会自动识别符合规范的POJO类，使用原生的POJO序列化器。该序列化器直接通过类字段赋值完成序列化/反序列化，不需要调用集合的add()方法，天然支持不可变集合。
你的Species类已经满足Flink POJO识别要求：公开类、存在无参构造方法、所有字段都有对应的Getter/Setter，可直接适配该方案。

方案3：给Kryo注册不可变集合序列化器 #

如果必须保留强制Kryo序列化的配置，可以手动给Kryo注册JDK不可变集合的专用序列化器：

1. 引入匹配Flink内置Kryo版本的不可变集合序列化器依赖
2. 在Flink环境配置中注册对应序列化器：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
// 注册不可变List的序列化器
env.getConfig().registerTypeWithKryoSerializer(List.of().getClass(), ImmutableListSerializer.class);
// 如果用到其他不可变集合，对应注册Set、Map的序列化器即可

内容的提问来源于stack exchange，提问作者user4695271