Index: src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java (revision 1543343) +++ src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java (working copy) @@ -627,20 +627,19 @@ nextHdfsOut = ((SequenceFileLogWriter)nextWriter).getWriterFSDataOutputStream(); } + Path oldFile = null; + int numEntriesSize = 0; synchronized (updateLock) { // Clean up current writer. - Path oldFile = cleanupCurrentWriter(currentFilenum); + oldFile = cleanupCurrentWriter(currentFilenum); this.writer = nextWriter; this.hdfs_out = nextHdfsOut; + numEntriesSize = this.numEntries.getAndSet(0); + } + LOG.info((oldFile != null ? "Roll " + FSUtils.getPath(oldFile) + ", entries=" + + numEntriesSize + ", filesize=" + this.fs.getFileStatus(oldFile).getLen() + ". " : "") + + " for " + FSUtils.getPath(newPath)); - LOG.info((oldFile != null? - "Roll " + FSUtils.getPath(oldFile) + ", entries=" + - this.numEntries.get() + - ", filesize=" + - this.fs.getFileStatus(oldFile).getLen() + ". ": "") + - " for " + FSUtils.getPath(newPath)); - this.numEntries.set(0); - } // Tell our listeners that a new log was created if (!this.listeners.isEmpty()) { for (WALActionsListener i : this.listeners) {