diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Journal.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Journal.java index 2c054a1d93b..5e857e0e91d 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Journal.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Journal.java @@ -385,8 +385,8 @@ public int process(boolean shouldForceWrite) throws IOException { this.logFile.forceWrite(false); journalStats.getJournalSyncStats() .registerSuccessfulEvent(MathUtils.elapsedNanos(startTime), TimeUnit.NANOSECONDS); + lastLogMark.setCurLogMark(this.logId, this.lastFlushedPosition); } - lastLogMark.setCurLogMark(this.logId, this.lastFlushedPosition); // Notify the waiters that the force write succeeded for (int i = 0; i < forceWriteWaiters.size(); i++) {