fix(query): fix interp pResBlock->rows > capacity cause assert failure

fb2bb048 · Ganlin Zhao · 92d42fab · fb2bb048
显示空白变更内容
内联并排

Showing with 1 addition and 3 deletion

source/libs/executor/src/timewindowoperator.c source/libs/executor/src/timewindowoperator.c +1 -3

未找到文件。
--- a/source/libs/executor/src/timewindowoperator.c
+++ b/source/libs/executor/src/timewindowoperator.c
@@ -2154,9 +2154,7 @@ static void doKeepLinearInfo(STimeSliceOperatorInfo* pSliceInfo, const SSDataBlo
 static void genInterpolationResult(STimeSliceOperatorInfo* pSliceInfo, SExprSupp* pExprSup, SSDataBlock* pResBlock) {
  int32_t rows = pResBlock->info.rows;
-  if (rows >= pResBlock->info.capacity) {
+  blockDataEnsureCapacity(pResBlock, rows + 1);
-    return;
-  }
  // todo set the correct primary timestamp column
  // output the result