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