>From Peeyush Gupta <[email protected]>:
Peeyush Gupta has uploaded this change for review. (
https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/18362 )
Change subject: WIP: fix recovery for atomic statements
......................................................................
WIP: fix recovery for atomic statements
Change-Id: I2a92e07b230f6a1d4aca2cacff8a568c29615238
---
M
asterixdb/asterix-app/src/main/java/org/apache/asterix/app/nc/IndexCheckpointManager.java
1 file changed, 10 insertions(+), 1 deletion(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/62/18362/1
diff --git
a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/nc/IndexCheckpointManager.java
b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/nc/IndexCheckpointManager.java
index 77a4f19..9463c88 100644
---
a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/nc/IndexCheckpointManager.java
+++
b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/nc/IndexCheckpointManager.java
@@ -236,7 +236,7 @@
final Collection<FileReference> checkpointFiles =
ioManager.list(indexPath, CHECKPOINT_FILE_FILTER);
if (!checkpointFiles.isEmpty()) {
for (FileReference checkpointFile : checkpointFiles) {
- if (getCheckpointIdFromFileName(checkpointFile) >
(latestId - historyToDelete)) {
+ if (read(checkpointFile).getLastComponentId() > (latestId
- historyToDelete)) {
ioManager.delete(checkpointFile);
}
}
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/18362
To unsubscribe, or for help writing mail filters, visit
https://asterix-gerrit.ics.uci.edu/settings
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Change-Id: I2a92e07b230f6a1d4aca2cacff8a568c29615238
Gerrit-Change-Number: 18362
Gerrit-PatchSet: 1
Gerrit-Owner: Peeyush Gupta <[email protected]>
Gerrit-MessageType: newchange
