Index: src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java (revision 1049745) +++ src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLog.java (working copy) @@ -493,6 +493,12 @@ nextHdfsOut = ((SequenceFileLogWriter)nextWriter).getDFSCOutputStream(); } + // Tell our listeners that a new log was created + if (!this.listeners.isEmpty()) { + for (WALObserver i : this.listeners) { + i.logRolled(newPath); + } + } synchronized (updateLock) { // Clean up current writer. Path oldFile = cleanupCurrentWriter(currentFilenum); @@ -509,12 +515,6 @@ this.numEntries.set(0); this.logRollRequested = false; } - // Tell our listeners that a new log was created - if (!this.listeners.isEmpty()) { - for (WALObserver i : this.listeners) { - i.logRolled(newPath); - } - } // Can we delete any of the old log files? if (this.outputfiles.size() > 0) { if (this.lastSeqWritten.isEmpty()) {