I would try to move the whole try/catch into one method to deduplicate code
with `shutdown()`, e.g.:
```
void tryRemove(Runnable doRemove) {
try {
// ..
doRemove.run(); // completedCheckpoint.discardOnSubsume(); or OnShutdown
// ..
} catch {
// ...
}
}
```[ Full content available at: https://github.com/apache/flink/pull/6587 ] This message was relayed via gitbox.apache.org for [email protected]
