FlinkFlink 报错 Corrupt data, magic number mismatch. Expected

Posted 九师兄

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了FlinkFlink 报错 Corrupt data, magic number mismatch. Expected相关的知识,希望对你有一定的参考价值。

1.概述

flink任务从检查点恢复报错 Corrupt data, magic number mismatch. Expected 详情信息如下

2.源码分析

首先在 org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshotReadersWriters.CurrentReaderImpl#readStateMetaInfoSnapshot 中调用

 @Nonnull
        @Override
        public StateMetaInfoSnapshot readStateMetaInfoSnapshot(
                @Nonnull 

以上是关于FlinkFlink 报错 Corrupt data, magic number mismatch. Expected的主要内容,如果未能解决你的问题,请参考以下文章

FlinkFlink 写入 kafka 报错 Transactional Id authorization failed

FlinkFlink 报错 Initial AbstractPagedOutputView Segment may not be null

FlinkFlink 做检查点 报错 Checkpoint Coordinator is suspending.

FlinkFlink 提交 任务 到 yarn 报错 NoClassDefFoundError ImutabMap

FlinkFlink 任务报错 Could not perform checkpoint for operator

FlinkFlink 监听 zk 地址 报错 InterruptedException null