fix(query): set retrieve completed flag for exchange operator.

2022-11-07 18:27:26 +08:00 · 2022-11-07 18:27:26 +08:00 · d016fc9d47
parent 9932fa6bf0
commit d016fc9d47
1 changed files with 4 additions and 0 deletions
--- a/source/libs/executor/src/executorimpl.c
+++ b/source/libs/executor/src/executorimpl.c
@ -1933,6 +1933,10 @@ static void concurrentlyLoadRemoteDataImpl(SOperatorInfo* pOperator, SExchangeIn
        }
      }

+      if (completed == totalSources) {
+        setAllSourcesCompleted(pOperator, startTs);
+      }
+
      return;
    }