Myasuka commented on pull request #10768: URL: https://github.com/apache/flink/pull/10768#issuecomment-620371410
@StephanEwen , I planed to complete requests by introducing async discard in checkpoint storage first in the past days, however, a very urgent and unexpected internal deadline breaks my previous schedule. Sorry for not creating promised commits in the past days. When talking about next changes, after discussed with @zhuzhurk offline, it was not so clear for me to move the shutdown of the `CheckpointStorage` to the shutdown of the `JobMaster`. We thought it was refer to current implementation of `Dispatcher#cleanUpJobData`, and I would add new interface to expose `CheckpointStorage` within `CheckpointCoordinator` outside to `ScheduleNG` and then to `JobMaster`, which might like current `ScheduleNG#stopWithSavepoint` to expose actions in `CheckpointCoordinator` outside. Any hints or suggestion is welcome. Since our internal deadline will end today, I plan to implement and offer commits to let directories could be discarded asynchronously tomorrow. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
