fix: continue execution after filter in project produces zero rows for next group

318360c2 · slzhou@taodata.com · d9f7c34a · 318360c2
显示空白变更内容
内联并排

Showing with 1 addition and 1 deletion

source/libs/executor/src/executorimpl.c source/libs/executor/src/executorimpl.c +1 -1

未找到文件。
--- a/source/libs/executor/src/executorimpl.c
+++ b/source/libs/executor/src/executorimpl.c
@@ -3355,7 +3355,7 @@ static SSDataBlock* doProjectOperation(SOperatorInfo* pOperator) {
      break;
    }
-    if (status == PROJECT_RETRIEVE_CONTINUE) {
+    if (status == PROJECT_RETRIEVE_CONTINUE || pInfo->pRes->info.rows == 0) {
      continue;
    } else if (status == PROJECT_RETRIEVE_DONE) {
      break;