diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c
index 21aab9fdbcf357ad8200b90c4a5c05461a567fce..9b5b23d9aaf585c769057fcbe0233fb4b3ac0fc4 100644
--- a/src/query/src/qExecutor.c
+++ b/src/query/src/qExecutor.c
@@ -4885,6 +4885,8 @@ static SSDataBlock* doIntervalAgg(void* param) {
       break;
     }
 
+    setTagValue(pOperator, pRuntimeEnv->pQuery->current->pTable, pIntervalInfo->pCtx, pOperator->numOfOutput);
+
     // the pDataBlock are always the same one, no need to call this again
     setInputDataBlock(pOperator, pIntervalInfo->pCtx, pBlock, pQuery->order.order);
     hashIntervalAgg(pOperator, &pIntervalInfo->resultRowInfo, pBlock, 0);