VIPFlink
Flink 任务扩缩容时,状态是如何重新分配的
先抓住题目的核心考点,再把答案拆成可复述的面试表达。
9 次浏览2026/8/8
先下定义一句话说清它是什么,面试官先听到结论。
再讲机制拆出关键流程、边界条件和常见坑位。
最后落场景结合生产经验,说出什么时候用、怎么权衡。
题目描述
请回答:Flink 任务扩缩容时,状态是如何重新分配的
这是 Flink 状态管理里很能区分理解深度的一题。很多人会回答:“扩容后把状态平均分给新的 Task,缩容后再合并回来。”这句话过于笼统。面试官真正想听的是:Keyed State 为什么依赖 Key Group,Max Parallelism 起什么作用,Operator State 的 Even-split 和 Union 有什么区别,以及扩缩容为什么需要从 Checkpoint 或 Savepoint 恢复。
评论
加载中...