flink 2.2.0 升级到2.2.1 switched from INITIALIZING to FAILED with failure cause: org.apache.flink.util.FlinkRuntimeException: Failed to deserialize value 这个是什么问题?
flink 2.2.0 升级到2.2.1 switched from INITIALIZING t[阿里云实时计算 Flink版]
「点点赞赏,手留余香」
还没有人赞赏,快来当第一个赞赏的人吧!
2.2.1版本的flink序列化的值有所调整,需要手动检查干预一下。
楼主你好,根据错误可以看到是你更新版本之后的序列化变化引起的,你可以排查一下序列化的设置。
这个错误可能是由于Flink升级到2.2.1后,序列化的值发生了变化,导致反序列化失败。可以尝试检查Flink应用程序中的序列化器,确保它们能够正确处理新版本的Flink中的值。