diff --git a/source/libs/executor/src/projectoperator.c b/source/libs/executor/src/projectoperator.c index 16eb569d3a6eabef1ecc6243f42f16d604a8c091..f2b79bf703343a8365b832b23dcd514e5ecc0574 100644 --- a/source/libs/executor/src/projectoperator.c +++ b/source/libs/executor/src/projectoperator.c @@ -241,7 +241,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; }