fix(query): set correct total rsp rows.

a898be4f · Haojun Liao · 7803104b · a898be4f
显示空白变更内容
内联并排

Showing with 1 addition and 4 deletion

source/libs/executor/src/exchangeoperator.c source/libs/executor/src/exchangeoperator.c +1 -4

未找到文件。
--- a/source/libs/executor/src/exchangeoperator.c
+++ b/source/libs/executor/src/exchangeoperator.c
@@ -218,10 +218,7 @@ static SSDataBlock* loadRemoteData(SOperatorInfo* pOperator) {
      if (status == PROJECT_RETRIEVE_CONTINUE) {
        continue;
      } else if (status == PROJECT_RETRIEVE_DONE) {
-        size_t rows = pBlock->info.rows;
+        if (pBlock->info.rows == 0) {
-        pExchangeInfo->limitInfo.numOfOutputRows += rows;
-        if (rows == 0) {
          setOperatorCompleted(pOperator);
          return NULL;
        } else {