akalash commented on a change in pull request #18354:
URL: https://github.com/apache/flink/pull/18354#discussion_r786110821
##########
File path: docs/content.zh/docs/ops/state/checkpointing_under_backpressure.md
##########
@@ -129,6 +129,10 @@ In-flight 数据后再生成 Watermark **。如果您的 Pipeline 中使用了**
使用对齐 Checkpoint产生**不同的结果**。如果您的 Operator 依赖于最新的 Watermark 始终可用，解决办法是将
Watermark
存放在 OperatorState 中。在这种情况下，Watermark 应该使用单键 group 存放在 UnionState 以方便扩缩容。
+#### Interplay with long-running record processing
+
+Despite that unaligned checkpoints barriers are able to overtake all other
records in the queue. The handling of this barrier still can be delayed if the
current record takes a lot of time to be processed. This situation can occur
when window operators emit heavy result or the flat map produce a lot of
records for a single input. It also can happen in any other situation when the
processing of the single record takes a while(a long record). As result, the
time of the checkpoint can be higher than expected or it can be volatile from
time to time.
Review comment:
As I see, we call it `network buffers` in documentation
--
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]
