From f3c89bdd2604b2ade31bf591092590e2f271b74e Mon Sep 17 00:00:00 2001 From: slzhou Date: Mon, 19 Sep 2022 13:25:54 +0800 Subject: [PATCH] fix: aggregation error when one group rows exceed int16_max --- src/query/src/qExecutor.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c index bb9ded8e40..985c35a009 100644 --- a/src/query/src/qExecutor.c +++ b/src/query/src/qExecutor.c @@ -1925,7 +1925,7 @@ static void doHashGroupbyAgg(SOperatorInfo* pOperator, SGroupbyOperatorInfo* pIn STimeWindow w = TSWINDOW_INITIALIZER; char* key = NULL; - int16_t num = 0; + int32_t num = 0; int32_t type = 0; for (int32_t j = 0; j < pSDataBlock->info.rows; ++j) { buildGroupbyKeyBuf(pSDataBlock, pInfo, j, &key); -- GitLab