fredia commented on code in PR #21822:
URL: https://github.com/apache/flink/pull/21822#discussion_r1140930335
##########
flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/LocalChangelogRegistryImpl.java:
##########
@@ -115,4 +116,32 @@ private void scheduleAsyncDelete(StreamStateHandle
streamStateHandle) {
}
}
}
+
+ @Override
+ public void close() throws IOException {
+ asyncDisposalExecutor.shutdown();
+ handleToLastUsedCheckpointID.clear();
+ }
+
+ /** A changelog handle and corresponding checkpointId in the local
registry. */
+ private static final class LocalStateEntry {
+ private StreamStateHandle handle;
+ private long createdCheckpointId;
+ private long lastUsedCheckpointId;
+
+ LocalStateEntry(StreamStateHandle handle, long checkpointId) {
+ this.handle = handle;
+ this.createdCheckpointId = checkpointId;
+ this.lastUsedCheckpointId = checkpointId;
+ }
+
+ public void advance(long checkpointId) {
Review Comment:
Since we don't need `LocalChangelogRegistry#prune(long)`, I deleted the
inner class.
--
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]
