From 58c4c54711fe84f5c97fbadfae010f6d3c7e2d89 Mon Sep 17 00:00:00 2001 From: 54liuyao <54liuyao> Date: Fri, 26 Jul 2024 20:51:01 +0800 Subject: [PATCH] adj operator result --- source/libs/executor/src/aggregateoperator.c | 2 +- source/libs/executor/src/timewindowoperator.c | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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; }