diff --git a/source/dnode/vnode/src/tq/tqUtil.c b/source/dnode/vnode/src/tq/tqUtil.c
index 8f9a490048..e78820bad8 100644
--- a/source/dnode/vnode/src/tq/tqUtil.c
+++ b/source/dnode/vnode/src/tq/tqUtil.c
@@ -28,11 +28,7 @@ char* createStreamTaskIdStr(int64_t streamId, int32_t taskId) {
 
 int32_t tqAddBlockNLaunchTask(SStreamTask* pTask, SPackedData *pPackedData) {
   SStreamDataSubmit* p = streamDataSubmitNew(pPackedData, STREAM_INPUT__DATA_SUBMIT);
-
   int32_t code = tAppendDataToInputQueue(pTask, (SStreamQueueItem*) p);
-  streamDataSubmitDestroy(p);
-  taosFreeQitem(p);
-
   if (code < 0) {
     tqError("s-task:%s failed to put into queue, too many, next start ver:%" PRId64, pTask->id.idStr, pPackedData->ver);
     return -1;