From c14721744ca3212fa3e4cbec4b5bbc797cf7b917 Mon Sep 17 00:00:00 2001 From: liuyao <54liuyao@163.com> Date: Fri, 15 Sep 2023 15:01:20 +0800 Subject: [PATCH] stream partition ignore stream_get_all --- source/libs/executor/src/groupoperator.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/source/libs/executor/src/groupoperator.c b/source/libs/executor/src/groupoperator.c index fb2204eae8..f5cabd823c 100644 --- a/source/libs/executor/src/groupoperator.c +++ b/source/libs/executor/src/groupoperator.c @@ -1132,7 +1132,8 @@ static SSDataBlock* doStreamHashPartition(SOperatorInfo* pOperator) { } break; case STREAM_CREATE_CHILD_TABLE: case STREAM_RETRIEVE: - case STREAM_CHECKPOINT: { + case STREAM_CHECKPOINT: + case STREAM_GET_ALL: { return pBlock; } default: