From 77a710cfeba164bcab95a6cd85ea73b72f48c625 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao@163.com>
Date: Fri, 12 Aug 2022 19:28:29 +0800
Subject: [PATCH] fix(stream): session delete

---
 source/libs/executor/src/projectoperator.c | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/source/libs/executor/src/projectoperator.c b/source/libs/executor/src/projectoperator.c
index 9a7c3cf7fb..1a38bc2829 100644
--- a/source/libs/executor/src/projectoperator.c
+++ b/source/libs/executor/src/projectoperator.c
@@ -240,7 +240,8 @@ SSDataBlock* doProjectOperation(SOperatorInfo* pOperator) {
       }
 
       // for stream interval
-      if (pBlock->info.type == STREAM_RETRIEVE) {
+      if (pBlock->info.type == STREAM_RETRIEVE || pBlock->info.type == STREAM_DELETE_RESULT ||
+          pBlock->info.type == STREAM_DELETE_DATA) {
         // printDataBlock1(pBlock, "project1");
         return pBlock;
       }