[TD-2145]<fix>: fix bugs in interval query.

3afd7a65 · Haojun Liao · 82246d44 · 3afd7a65
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

src/query/src/qResultbuf.c src/query/src/qResultbuf.c +1 -1

未找到文件。
--- a/src/query/src/qResultbuf.c
+++ b/src/query/src/qResultbuf.c
@@ -165,7 +165,7 @@ static char* doFlushPageToDisk(SDiskbasedResultBuf* pResultBuf, SPageInfo* pg) {

 static char* flushPageToDisk(SDiskbasedResultBuf* pResultBuf, SPageInfo* pg) {
  int32_t ret = TSDB_CODE_SUCCESS;
-  assert(pResultBuf->numOfPages * pResultBuf->pageSize == pResultBuf->totalBufSize && pResultBuf->numOfPages >= pResultBuf->inMemPages);
+  assert(((int64_t) pResultBuf->numOfPages * pResultBuf->pageSize) == pResultBuf->totalBufSize && pResultBuf->numOfPages >= pResultBuf->inMemPages);

  if (pResultBuf->file == NULL) {
    if ((ret = createDiskFile(pResultBuf)) != TSDB_CODE_SUCCESS) {