diff --git a/src/mnode/src/mnodeSdb.c b/src/mnode/src/mnodeSdb.c
index 90f70e936b7d41e27389d142961fbb70b3e9deb5..cdcb7357f1a88c9a21097a9c1532e129cf0473db 100644
--- a/src/mnode/src/mnodeSdb.c
+++ b/src/mnode/src/mnodeSdb.c
@@ -967,12 +967,11 @@ static void *sdbWorkerFp(void *param) {
       }
 
       int32_t code = sdbWrite(pOper, pHead, type);
-      if (code < 0) {
-        if (pOper)
-          pOper->retCode = code;
-        else
-          pHead->len = code;  // hackway
-      }
+      if (code > 0) code = 0;
+      if (pOper)
+        pOper->retCode = code;
+      else
+        pHead->len = code;  // hackway
     }
 
     walFsync(tsSdbObj.wal);