used for taking a checkpointsavepoint is used when restoring

used for taking a checkpointsavepoint is used when restoring,第1张

used for taking a checkpoint/savepoint is used when restoring java.lang.IllegalStateException: Unexpected state handle type, expected one of: class org.apache.flink.runtime.state.KeyGroupsStateHandle, but found: class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle. This can mostly happen when a different StateBackend from the one that was used for taking a checkpoint/savepoint is used when restoring.

yarn 上任务显示如下:

原因
选择的 checkpoint 文件有问题

解决
更换为更早的checkpoint , 重启解决

欢迎分享,转载请注明来源:内存溢出

原文地址: https://outofmemory.cn/zaji/5679233.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-17
下一篇 2022-12-17

发表评论

登录后才能评论

评论列表(0条)

保存