diff --git a/source/libs/executor/src/aggregateoperator.c b/source/libs/executor/src/aggregateoperator.c index 24da11eb06..f1e5dcb670 100644 --- a/source/libs/executor/src/aggregateoperator.c +++ b/source/libs/executor/src/aggregateoperator.c @@ -303,7 +303,7 @@ _end: static SSDataBlock* getAggregateResult(SOperatorInfo* pOperator) { SSDataBlock* pRes = NULL; - int32_t code = getAggregateResultNext(pOperator, &pRes); + int32_t code = getAggregateResultNext(pOperator, &pRes); return pRes; } diff --git a/source/libs/executor/src/timewindowoperator.c b/source/libs/executor/src/timewindowoperator.c index 14d1908e55..1279d5f850 100644 --- a/source/libs/executor/src/timewindowoperator.c +++ b/source/libs/executor/src/timewindowoperator.c @@ -2278,7 +2278,7 @@ _end: static SSDataBlock* doMergeIntervalAgg(SOperatorInfo* pOperator) { SSDataBlock* pRes = NULL; - int32_t code = doMergeIntervalAggNext(pOperator, &pRes); + int32_t code = doMergeIntervalAggNext(pOperator, &pRes); return pRes; }