diff --git a/src/wal/src/walMain.c b/src/wal/src/walMain.c index 7ec55bbf1f..ab324bcfad 100644 --- a/src/wal/src/walMain.c +++ b/src/wal/src/walMain.c @@ -208,7 +208,10 @@ int walRestore(void *handle, void *pVnode, int (*writeFp)(void *, void *, int)) } } - if (count == 0) return 0; + if (count == 0) { + if (pWal->keep) code = walRenew(pWal); + return code; + } if ( count != (maxId-minId+1) ) { wError("wal:%s, messed up, count:%d max:%d min:%d", opath, count, maxId, minId);