fix: invalid vg count

6c039c45 · dengyihao · 92ba51a4 · 6c039c45
隐藏空白更改
内联并排

Showing with 0 addition and 2 deletion

source/libs/function/src/builtinsimpl.c source/libs/function/src/builtinsimpl.c +0 -2

未找到文件。
--- a/source/libs/function/src/builtinsimpl.c
+++ b/source/libs/function/src/builtinsimpl.c
@@ -5438,8 +5438,6 @@ int32_t blockDistFunction(SqlFunctionCtx* pCtx) {
  if (pDistInfo->maxRows < p1.maxRows) {
    pDistInfo->maxRows = p1.maxRows;
  }
-  pDistInfo->numOfVgroups += (p1.numOfTables != 0 ? 1 : 0);
  pDistInfo->numOfVgroups += (p1.numOfTables != 0 ? 1 : 0);
  for (int32_t i = 0; i < tListLen(pDistInfo->blockRowsHisto); ++i) {
    pDistInfo->blockRowsHisto[i] += p1.blockRowsHisto[i];