enh: tolerate exec error

ecbc0966 · Liu Jicong · c0c98320 · ecbc0966
隐藏空白更改
内联并排

Showing with 1 addition and 0 deletion

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

未找到文件。
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -54,6 +54,7 @@ static int32_t streamTaskExecImpl(SStreamTask* pTask, const void* data, SArray*
      /*ASSERT(false);*/
      qError("unexpected stream execution, stream %" PRId64 " task: %d,  since %s", pTask->streamId, pTask->taskId,
             terrstr());
+      continue;
    }
    if (output == NULL) {
      if (pItem->type == STREAM_INPUT__DATA_RETRIEVE) {