enh: drop stream eagerly

5826e40a · Liu Jicong · 1b046dd9 · 5826e40a
隐藏空白更改
内联并排

Showing with 4 addition and 0 deletion

source/libs/stream/src/streamExec.c source/libs/stream/src/streamExec.c +4 -0

未找到文件。
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -48,6 +48,10 @@ static int32_t streamTaskExecImpl(SStreamTask* pTask, const void* data, SArray*

  // exec
  while (1) {
+    if (pTask->taskStatus == TASK_STATUS__DROPPING) {
+      return 0;
+    }
+
    SSDataBlock* output = NULL;
    uint64_t     ts = 0;
    if ((code = qExecTask(exec, &output, &ts)) < 0) {