|
@@ -712,7 +712,8 @@ class OpenFileCtx {
|
|
LOG.debug("Got commit status: " + ret.name());
|
|
LOG.debug("Got commit status: " + ret.name());
|
|
}
|
|
}
|
|
// Do the sync outside the lock
|
|
// Do the sync outside the lock
|
|
- if (ret == COMMIT_STATUS.COMMIT_DO_SYNC) {
|
|
|
|
|
|
+ if (ret == COMMIT_STATUS.COMMIT_DO_SYNC
|
|
|
|
+ || ret == COMMIT_STATUS.COMMIT_FINISHED) {
|
|
try {
|
|
try {
|
|
// Sync file data and length
|
|
// Sync file data and length
|
|
fos.hsync(EnumSet.of(SyncFlag.UPDATE_LENGTH));
|
|
fos.hsync(EnumSet.of(SyncFlag.UPDATE_LENGTH));
|