Dennis-Mircea commented on code in PR #28094: URL: https://github.com/apache/flink/pull/28094#discussion_r3233898976
########## docs/content.zh/docs/ops/state/state_backends.md: ########## @@ -56,10 +56,15 @@ Flink 内置了以下这些开箱即用的 state backends : 在 *HashMapStateBackend* 内部,数据以 Java 对象的形式存储在堆中。 Key/value 形式的状态和窗口算子会持有一个 hash table,其中存储着状态值、触发器。 +HashMapStateBackend 的局限: + + - 状态大小受限于 TaskManager 上可用的 JVM 堆内存。从 checkpoint 或 savepoint 恢复时,每个 TaskManager 必须有足够的堆内存来容纳其分配到的状态。 + - 仅支持全量快照,不支持增量 checkpoint。每次 checkpoint 都会捕获完整的状态,随着状态规模增长,checkpoint 时长和恢复时间也会随之延长。 + HashMapStateBackend 的适用场景: - - 有较大 state,较长 window 和较大 key/value 状态的 Job。 - - 所有的高可用场景。 + - 状态可以完全放入 TaskManager JVM 堆内存的 Job,需要快速、基于内存的状态访问。 Review Comment: @klion26 Can you take a look on this one? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
