File tree Expand file tree Collapse file tree
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -1006,7 +1006,7 @@ public Path getCurrentFileName() {
10061006 public long getFilenum () {
10071007 return filenum .get ();
10081008 }
1009-
1009+
10101010 @ Override
10111011 public String toString () {
10121012 return "FSHLog " + logFilePrefix + ":" + logFileSuffix + "(num " + filenum + ")" ;
@@ -1283,8 +1283,12 @@ public void run() {
12831283 Throwable lastException = null ;
12841284 try {
12851285 Trace .addTimelineAnnotation ("syncing writer" );
1286+ long unSyncedFlushSeq = highestUnsyncedSequence ;
12861287 writer .sync ();
12871288 Trace .addTimelineAnnotation ("writer synced" );
1289+ if (unSyncedFlushSeq > currentSequence ) {
1290+ currentSequence = unSyncedFlushSeq ;
1291+ }
12881292 currentSequence = updateHighestSyncedSequence (currentSequence );
12891293 } catch (IOException e ) {
12901294 LOG .error ("Error syncing, request close of WAL" , e );
You can’t perform that action at this time.
0 commit comments