Flink抛出java.io.NotSerializableException

当在 Apache Flink 中遇到 java.io.NotSerializableException 异常时，通常是因为在 Flink 作业中使用了不可序列化的对象。Flink 在执行分布式计算时需要将数据序列化并在不同的节点之间传输，因此所有在 Flink 作业中使用的对象都必须是可序列化的。

要解决这个问题，你可以采取以下几个步骤：

1. 确保你的自定义类实现了 java.io.Serializable 接口。这个接口标识了一个类是可序列化的，并且可以被 Flink 序列化和传输。
2. 避免在 Flink 作业中使用不可序列化的对象。例如，避免在函数中引用外部的非序列化对象，或者将非序列化对象作为算子的状态。
3. 如果你需要在 Flink 作业中使用不可序列化的对象，可以考虑使用 Flink 的 ValueState 或 ListState 等状态后端来存储这些对象。这样，你可以将对象存储在状态中，而不是直接在算子中使用。
4. 如果你使用了第三方库或框架，确保它们提供了可序列化的对象。有些库可能需要特殊的配置或使用特定的序列化器来支持 Flink。