diff --git a/src/wal/src/walMain.c b/src/wal/src/walMain.c index 7ec55bbf1f1e44cf319d60e75f5da7753ef762d3..ab324bcfad10b131238b911e895c99d0a343e5f1 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);