From 2b924c68fd95adf583aec76d8acf78b0a37968c7 Mon Sep 17 00:00:00 2001 From: 54liuyao <54liuyao@163.com> Date: Mon, 28 Oct 2024 18:08:18 +0800 Subject: [PATCH] ignore delete result --- source/libs/executor/src/scanoperator.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c index 8c04492162..12ec7d4201 100644 --- a/source/libs/executor/src/scanoperator.c +++ b/source/libs/executor/src/scanoperator.c @@ -3798,7 +3798,7 @@ FETCH_NEXT_BLOCK: QUERY_CHECK_CODE(code, lino, _end); deletePartName(pInfo, pBlock); - pBlock->info.type = STREAM_DELETE_DATA; + goto FETCH_NEXT_BLOCK; } break; case STREAM_CHECKPOINT: { qError("stream check point error. msg type: STREAM_INPUT__DATA_BLOCK");