zhuzhurk commented on code in PR #24855:
URL: https://github.com/apache/flink/pull/24855#discussion_r1618464994
##########
docs/content.zh/docs/ops/batch/recovery_from_job_master_failure.md:
##########
@@ -75,6 +75,19 @@ JobMaster failover 后能够尽可能的恢复出错前的进度，避免重新
- [job-event.store.write-buffer.size]({{< ref "docs/deployment/config"
>}}#job-event-store-write-buffer-size)：
JobEventStore 写出缓冲区的大小。一旦缓冲区满了，内容将被刷新到外部文件系统。
+### 让 Source 支持 job master failover 后进度恢复
+
+目前，仅 new source (FLIP-27) 支持批处理作业的进度恢复。为了实现这一功能，new source 的 SplitEnumerator
需要实现 SupportsBatchSnapshot 接口：
Review Comment:
为了实现这一功能，new source 的 SplitEnumerator 需要实现 SupportsBatchSnapshot 接口：
-> New source 的 SplitEnumerator 需要能够支持批处理场景下的
snapshotState(checkpointId=-1)，并且实现 [SupportsBatchSnapshot]({{< ref "xxx"
>}}#yyy) 接口，从而能够在重启后恢复到出错前的状态。
--
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]
