diff --git a/source/libs/executor/src/executorimpl.c b/source/libs/executor/src/executorimpl.c index b76698b0bca022a3c89ee982b0641b6b28132d71..0e2f2189bd700a3066de85aaf438715d34e12155 100644 --- 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; }