diff --git a/source/libs/stream/src/streamQueue.c b/source/libs/stream/src/streamQueue.c
index 954e41f288..4139a5ccb7 100644
--- a/source/libs/stream/src/streamQueue.c
+++ b/source/libs/stream/src/streamQueue.c
@@ -144,21 +144,11 @@ void streamQueueNextItemInSourceQ(SStreamQueue* pQueue, SStreamQueueItem** pItem
 
   // let's try the ordinary input q
   pQueue->qItem = NULL;
-  int32_t code = taosGetQitem(pQueue->qall, &pQueue->qItem);
-  if (code) {
-    stError("s-task:%s failed to get item in inputq, code:%s", id, tstrerror(code));
-  }
+  int32_t num = taosGetQitem(pQueue->qall, &pQueue->qItem);
 
   if (pQueue->qItem == NULL) {
-    code = taosReadAllQitems(pQueue->pQueue, pQueue->qall);
-    if (code) {
-      stError("s-task:%s failed to get all items in inputq, code:%s", id, tstrerror(code));
-    }
-
-    code = taosGetQitem(pQueue->qall, &pQueue->qItem);
-    if (code) {
-      stError("s-task:%s failed to get item in inputq, code:%s", id, tstrerror(code));
-    }
+    num = taosReadAllQitems(pQueue->pQueue, pQueue->qall);
+    num = taosGetQitem(pQueue->qall, &pQueue->qItem);
   }
 
   *pItem = streamQueueCurItem(pQueue);