flink 2.2.0 升级到2.2.1 switched from INITIALIZING t[阿里云实时计算 Flink版]

flink 2.2.0 升级到2.2.1 switched from INITIALIZING to FAILED with failure cause: org.apache.flink.util.FlinkRuntimeException: Failed to deserialize value 这个是什么问题?

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
2 条回复 A 作者 M 管理员
  1. 2.2.1版本的flink序列化的值有所调整,需要手动检查干预一下。

  2. 楼主你好,根据错误可以看到是你更新版本之后的序列化变化引起的,你可以排查一下序列化的设置。

  3. 这个错误可能是由于Flink升级到2.2.1后,序列化的值发生了变化,导致反序列化失败。可以尝试检查Flink应用程序中的序列化器,确保它们能够正确处理新版本的Flink中的值。