diff --git a/src/query/src/qResultbuf.c b/src/query/src/qResultbuf.c
index dfa8bcd95bd43e5030540e9380eaf534e6580897..55a7aea53a8d53ef66bf33eaa73a47d8cf0d77b6 100644
--- a/src/query/src/qResultbuf.c
+++ b/src/query/src/qResultbuf.c
@@ -122,7 +122,7 @@ static char* doFlushPageToDisk(SDiskbasedResultBuf* pResultBuf, SPageInfo* pg) {
     int32_t ret = fseek(pResultBuf->file, pg->info.offset, SEEK_SET);
     assert(ret == 0);
 
-    ret = fwrite(t, 1, size, pResultBuf->file);
+    ret = (int32_t) fwrite(t, 1, size, pResultBuf->file);
     assert(ret == size);
 
     if (pResultBuf->fileSize < pg->info.offset + pg->info.length) {