Flink The new key serializer must be compatible with the previous key serializer
Posted 九师兄
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flink The new key serializer must be compatible with the previous key serializer相关的知识，希望对你有一定的参考价值。
文章目录
1.概述
我flink任务，修改keyby字段的个数(由之前的2个key到现在3个key)后从savePoint中启动报错，这种情况需要怎么处理呢？
2. 源码分析
KeyedBackendSerializationProxy<K
创作打卡挑战赛
赢取流量/现金/CSDN周边激励大奖
以上是关于Flink The new key serializer must be compatible with the previous key serializer的主要内容，如果未能解决你的问题，请参考以下文章
Flinkflink 状态恢复 because the operator is not available in the new program
flink运行报错 org.apache.flink.client.program.ProgramInvocationException: Could not retrieve the executi
Flink 1.11+ No ExecutorFactory found to execute the application
Flink SQL Size of the state is larger than the maximum permitted memory-backed state