问题描述/异常栈

org.apache.flink.util.StateMigrationException: For heap backends, the new state serializer (org.apache.flink.table.runtime.typeutils.RowDataSerializer@1703f2a3) must not be incompatible with the old state serializer (org.apache.flink.table.runtime.typeutils.RowDataSerializer@8228dc41).
at org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.tryRegisterStateTable(HeapKeyedState

解决方案

选择直接启动，从非checkpoint重启。

问题原因

datahub新增了一个字段，从checkpoint重启运行失败。

作者：邓崃翔