fredia commented on code in PR #22890: URL: https://github.com/apache/flink/pull/22890#discussion_r1328451234
########## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManager.java: ########## @@ -31,7 +32,7 @@ * FileMergingSnapshotManager provides an interface to manage files and meta information for * checkpoint files with merging checkpoint files enabled. It manages the files for ONE single task * in TM, including all subtasks of this single task that running in this TM. There is one - * FileMergingSnapshotManager for each task per task manager. + * FileMergingSnapshotManager for each job per task manager. Review Comment: > If a job has multiple tasks on the same TM (not sub-tasks), do they share the same FileMergingSnapshotManager? Yes, they share the same `FileMergingSnapshotManager`, and "(Source 0/1)" " (MAP 0/1)" have different `OperatorId`, so they would have their own subdirectories. -- 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]
