Skip to content

Commit

Permalink
fix ident
Browse files Browse the repository at this point in the history
  • Loading branch information
huan233usc committed Feb 3, 2025
1 parent 9278d0b commit 396e902
Showing 1 changed file with 8 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -412,15 +412,14 @@ public void insertWithOptionalCheckpoint(String tablePath) throws IOException {
for(PostCommitAction action: commitResult.getPostCommitActions())
// Checkpoint the table
didCheckpoint = didCheckpoint || CompletableFuture.supplyAsync(() -> {
// run the code async
try{
action.threadSafeInvoke();
} catch (IOException e) {
return false;
}
return action.getType().equals("checkpoint");
}
).join(); // wait async finish.
// run the code async
try{
action.threadSafeInvoke();
} catch (IOException e) {
return false;
}
return action.getType().equals("checkpoint");
}).join(); // wait async finish.
}

if (!didCheckpoint) {
Expand Down

0 comments on commit 396e902

Please sign in to comment.