This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 23814be4f91 [hotfix][docs-zh]Fix Chinese document format errors.
23814be4f91 is described below
commit 23814be4f916b064be082a5382d9c5c5fab10ff3
Author: liuzhuang2017 <justd...@outlook.com>
AuthorDate: Tue Jul 12 17:00:59 2022 +0800
[hotfix][docs-zh]Fix Chinese document format errors.
---
docs/content.zh/docs/ops/state/checkpointing_under_backpressure.md | 4 ++--
docs/content.zh/docs/ops/state/large_state_tuning.md | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/docs/content.zh/docs/ops/state/checkpointing_under_backpressure.md
b/docs/content.zh/docs/ops/state/checkpointing_under_backpressure.md
index 15a9be9ff12..3383f21d703 100644
--- a/docs/content.zh/docs/ops/state/checkpointing_under_backpressure.md
+++ b/docs/content.zh/docs/ops/state/checkpointing_under_backpressure.md
@@ -124,8 +124,8 @@ Checkpoint。此外，Savepoint 也不能与非对齐 Checkpoint 同时发生，
#### 与 Watermark 的相互影响
非对齐 Checkpoint 在恢复的过程中改变了关于 Watermark 的一个隐式保证。目前，Flink 确保了 Watermark 作为恢复的第一步，
-而不是将最近的 Watermark 存放在 Operator 中，以方便扩缩容。在非对齐 Checkpoint 中，这意味着当恢复时，** Flink
会在恢复
-In-flight 数据后再生成 Watermark **。如果您的 Pipeline 中使用了**对每条记录都应用最新的 Watermark
的算子**将会相对于
+而不是将最近的 Watermark 存放在 Operator 中，以方便扩缩容。在非对齐 Checkpoint 中，这意味着当恢复时，**Flink 会在恢复
+In-flight 数据后再生成 Watermark**。如果您的 Pipeline 中使用了**对每条记录都应用最新的 Watermark
的算子**将会相对于
使用对齐 Checkpoint产生**不同的结果**。如果您的 Operator 依赖于最新的 Watermark 始终可用，解决办法是将
Watermark
存放在 OperatorState 中。在这种情况下，Watermark 应该使用单键 group 存放在 UnionState 以方便扩缩容。
diff --git a/docs/content.zh/docs/ops/state/large_state_tuning.md
b/docs/content.zh/docs/ops/state/large_state_tuning.md
index 53de77b47a2..a7499ee12ca 100644
--- a/docs/content.zh/docs/ops/state/large_state_tuning.md
+++ b/docs/content.zh/docs/ops/state/large_state_tuning.md
@@ -173,7 +173,7 @@ Flink 的设计力求使最大并行度的值达到很高的效率，即使执
## 压缩
-Flink 为所有 checkpoints 和 savepoints 提供可选的压缩（默认：关闭）。 目前，压缩总是使用 [snappy 压缩算法（版本
1.1.4）]（https://github.com/xerial/snappy-java），
+Flink 为所有 checkpoints 和 savepoints 提供可选的压缩（默认：关闭）。 目前，压缩总是使用 [snappy 压缩算法（版本
1.1.4）](https://github.com/xerial/snappy-java),
但我们计划在未来支持自定义压缩算法。 压缩作用于 keyed state 下 key-groups 的粒度，即每个 key-groups
可以单独解压缩，这对于重新缩放很重要。
可以通过 `ExecutionConfig` 开启压缩：
