stream partition ignore stream_get_all

2023-09-15 15:01:20 +08:00 · 2023-09-15 15:01:20 +08:00 · c14721744c
parent 733002564a
commit c14721744c
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: