VIPFlink

Flink 任务扩缩容时,状态是如何重新分配的

先抓住题目的核心考点,再把答案拆成可复述的面试表达。

9 次浏览2026/8/8
先下定义一句话说清它是什么,面试官先听到结论。
再讲机制拆出关键流程、边界条件和常见坑位。
最后落场景结合生产经验,说出什么时候用、怎么权衡。

题目描述

请回答:Flink 任务扩缩容时,状态是如何重新分配的

这是 Flink 状态管理里很能区分理解深度的一题。很多人会回答:“扩容后把状态平均分给新的 Task,缩容后再合并回来。”这句话过于笼统。面试官真正想听的是:Keyed State 为什么依赖 Key Group,Max Parallelism 起什么作用,Operator State 的 Even-split 和 Union 有什么区别,以及扩缩容为什么需要从 Checkpoint 或 Savepoint 恢复。

参考答案

评论

登录 后参与评论

加载中...