为你的 Flink 程序注册自定义序列化器

需要确保你的自定义序列化器继承了 Kryo 的序列化器类。对于 Google Protobuf 或 Apache Thrift，这一点已经为你做好了：

对于 Google Protobuf 需要添加以下 Maven 依赖：

如果你为自定义类型注册 Kryo 的，即使你提交的 jar 中包含了自定义类型的类，也可能会遇到异常。这是由于 Kryo 的一个已知问题，它可能使用了错误的类加载器。