关于 Flink State 的元数据

shengjk1

发布于 2025-05-16 11:06:48

7400

代码可运行

文章被收录于专栏：码字搬砖码字搬砖

运行总次数：0

代码可运行

结论：

Flink State 是有元数据的，元数据发生改变后，Flink 就无法从 ck 或者 savepoint 中恢复。

现象

有时候明明没有改动关于 state 的任何东西，但突然报错了

Caused by: java.lang.Exception: error while restore processing keyedStatedBackend!
	at org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.keyedStatedBackend(StreamTaskStateInitializerImpl.java:372)
	at org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.streamOperatorStateContext(StreamTaskStateInitializerImpl.java:172)

error while restore processing keyedStatedBackend! 就很奇怪了。细细查看就发了改变的 keyby 对应的 value，然后就会觉得很奇怪，为啥改变它会无法从 ck 中恢复呢？