知识卡片
状态扩容要重分布
内容
修改并行度时,状态必须在新的子任务之间重新分配,否则同一 Key 或分片的历史记忆会丢失。发散:流作业扩容难,难在数据和状态要一起搬家。
参考来源
- 位置:《Flink原理与实践》第6章《状态和检查点》(源文件:_epub-src/OEBPS/Text/chapter09.xhtml)
- 结论依据:原文围绕“状态也能自动重新分布到多个并行子任务上”给出定义、流程、对比或限制条件,本卡片据此提炼其可迁移的框架机制,并补充了使用边界或工程启发。
- 原始内容:当我们横向扩展,或者说我们修改Flink应用的并行度时,状态也能自动重新分布到多个并行子任务上。