StefanRRichter commented on code in PR #24031:
URL: https://github.com/apache/flink/pull/24031#discussion_r1481180416
##########
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/restore/RocksDBIncrementalRestoreOperation.java:
##########
@@ -539,13 +552,14 @@ private void rescaleClipIngestDB(
}
// If there are temporary instances for which we detected overlap
in the buffer or
- // if we have remaining handles to restore, we will insert by copy
with from temporary
- // instances to base DB.
+ // if we have remaining unopened handles to restore, we will
insert by copy via
+ // temporary instances to base DB.
Review Comment:
Yes, I'm already working on adding that code again here.
--
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]
