diff --git a/source/dnode/vnode/src/inc/tq.h b/source/dnode/vnode/src/inc/tq.h
index 9a89c732bd..104e0945ba 100644
--- a/source/dnode/vnode/src/inc/tq.h
+++ b/source/dnode/vnode/src/inc/tq.h
@@ -182,9 +182,9 @@ int32_t         tqOffsetDelete(STqOffsetStore* pStore, const char* subscribeKey)
 int32_t         tqOffsetCommitFile(STqOffsetStore* pStore);
 
 // tqSink
-// void tqSinkToTableMerge(SStreamTask* pTask, void* vnode, int64_t ver, void* data);
-// void tqSinkToTablePipeline(SStreamTask* pTask, void* vnode, int64_t ver, void* data);
-void tqSinkToTablePipeline2(SStreamTask* pTask, void* vnode, int64_t ver, void* data);
+int32_t tqBuildDeleteReq(SVnode* pVnode, const char* stbFullName, const SSDataBlock* pDataBlock,
+                         SBatchDeleteReq* deleteReq);
+void    tqSinkToTablePipeline2(SStreamTask* pTask, void* vnode, int64_t ver, void* data);
 
 // tqOffset
 char*   tqOffsetBuildFName(const char* path, int32_t fVer);
diff --git a/source/dnode/vnode/src/sma/smaTimeRange.c b/source/dnode/vnode/src/sma/smaTimeRange.c
index 2179d96fe1..dead3615d0 100644
--- a/source/dnode/vnode/src/sma/smaTimeRange.c
+++ b/source/dnode/vnode/src/sma/smaTimeRange.c
@@ -14,6 +14,7 @@
  */
 
 #include "sma.h"
+#include "tq.h"
 #include "tsdb.h"
 
 #define SMA_STORAGE_MINUTES_MAX  86400
@@ -330,7 +331,7 @@ int32_t smaBlockToSubmit(SVnode *pVnode, const SArray *pBlocks, const STSchema *
     tEncoderInit(&encoder, POINTER_SHIFT(pBuf, sizeof(SMsgHead)), len - sizeof(SMsgHead));
     if (tEncodeSSubmitReq2(&encoder, pReq) < 0) {
       terrno = TSDB_CODE_OUT_OF_MEMORY;
-      tqError("failed to encode submit req since %s", terrstr());
+      /*vError("failed to encode submit req since %s", terrstr());*/
     }
     tEncoderClear(&encoder);
   }