diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c
index 166fcf33970806b84429a5f21f5ad997cf4d8bb6..9424200840f4599bc6bb67e80396c5587bb7d811 100644
--- a/src/query/src/qExecutor.c
+++ b/src/query/src/qExecutor.c
@@ -7770,6 +7770,7 @@ SOperatorInfo* createTimeIntervalOperatorInfo(SQueryRuntimeEnv* pRuntimeEnv, SOp
   initResultRowInfo(&pInfo->resultRowInfo, 8, TSDB_DATA_TYPE_INT);
 
   if (pInfo->pRes == NULL || pInfo->pCtx == NULL || pInfo->resultRowInfo.pResult == NULL) {
+    free(pOperator);
     goto _clean;
   }