diff --git a/source/libs/executor/src/streamfilloperator.c b/source/libs/executor/src/streamfilloperator.c index cd7ab547d4..ccf1f7c9e5 100644 --- a/source/libs/executor/src/streamfilloperator.c +++ b/source/libs/executor/src/streamfilloperator.c @@ -1270,7 +1270,9 @@ static int32_t doStreamForceFillImpl(SOperatorInfo* pOperator) { TSKEY resTs = tsCol[i]; while (resTs < (*pTs)) { SWinKey key = {.groupId = groupId, .ts = resTs}; - taosArrayPush(pInfo->pUpdated, &key); + void* pPushRes = taosArrayPush(pInfo->pUpdated, &key); + QUERY_CHECK_NULL(pPushRes, code, lino, _end, terrno); + if (IS_FILL_CONST_VALUE(pFillSup->type)) { break; }