Merge pull request #22923 from taosdata/fix/TS-4001

stream partition ignore stream_get_all
2023-09-15 17:37:09 +08:00 · 2023-09-15 17:37:09 +08:00 · 6bb752b92e
parent 72d942a0f0 c14721744c
commit 6bb752b92e
1 changed files with 2 additions and 1 deletions
--- 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: