Murtadha Hubail has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/2457
Change subject: [NO ISSUE][STO] Stop After First Successful Checkpoint Write
......................................................................
[NO ISSUE][STO] Stop After First Successful Checkpoint Write
- user model changes: no
- storage format changes: no
- interface changes: no
Change-Id: Idaaa01dd7c6db03f25a496d1ff7a71a1488d5fff
---
M
asterixdb/asterix-app/src/main/java/org/apache/asterix/app/nc/IndexCheckpointManager.java
1 file changed, 2 insertions(+), 0 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/57/2457/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 d3ef028..4bac16f 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
@@ -151,12 +151,14 @@
// clean up from previous write failure
if (checkpointPath.toFile().exists()) {
Files.delete(checkpointPath);
+ System.out.println("Deleted " + checkpoint);
}
try (BufferedWriter writer =
Files.newBufferedWriter(checkpointPath)) {
writer.write(checkpoint.asJson());
}
// ensure it was written correctly by reading it
read(checkpointPath);
+ return;
} catch (IOException e) {
if (i == MAX_CHECKPOINT_WRITE_ATTEMPTS) {
throw HyracksDataException.create(e);
--
To view, visit https://asterix-gerrit.ics.uci.edu/2457
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: Idaaa01dd7c6db03f25a496d1ff7a71a1488d5fff
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Murtadha Hubail <[email protected]>
