From a4d2dfed6784098a361bcb0b504c43de48283ca5 Mon Sep 17 00:00:00 2001
From: wangjiaming0909 <604227650@qq.com>
Date: Sun, 4 Feb 2024 14:34:14 +0800
Subject: [PATCH] stream supported api

---
 source/dnode/vnode/src/tq/tqSink.c   | 4 ++--
 source/libs/catalog/inc/catalogInt.h | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/source/dnode/vnode/src/tq/tqSink.c b/source/dnode/vnode/src/tq/tqSink.c
index b060de029c..f7003ca41b 100644
--- a/source/dnode/vnode/src/tq/tqSink.c
+++ b/source/dnode/vnode/src/tq/tqSink.c
@@ -794,8 +794,8 @@ int32_t setDstTableDataUid(SVnode* pVnode, SStreamTask* pTask, SSDataBlock* pDat
   return TDB_CODE_SUCCESS;
 }
 
-int32_t tqSetDstTableDataPayload(uint64_t suid, const STSchema* pTSchema, int32_t blockIndex, SSDataBlock* pDataBlock,
-                                 SSubmitTbData* pTableData, const char* id) {
+int32_t tqSetDstTableDataPayload(uint64_t suid, const STSchema *pTSchema, int32_t blockIndex, SSDataBlock* pDataBlock,
+                               SSubmitTbData* pTableData, const char* id) {
   int32_t numOfRows = pDataBlock->info.rows;
 
   tqDebug("s-task:%s sink data pipeline, build submit msg from %dth resBlock, including %d rows, dst suid:%" PRId64, id,
diff --git a/source/libs/catalog/inc/catalogInt.h b/source/libs/catalog/inc/catalogInt.h
index c27f82a890..dbaf4b4aa7 100644
--- a/source/libs/catalog/inc/catalogInt.h
+++ b/source/libs/catalog/inc/catalogInt.h
@@ -275,7 +275,7 @@ typedef STableTSMAInfo STSMACache;
 typedef struct SCtgTbCache {
   SRWLatch           metaLock;
   SRWLatch           indexLock;
-  SRWLatch           tsmaLock;
+  SRWLatch           tsmaLock;// TODO remove?
   STableMeta*        pMeta;
   STableIndex*       pIndex;
 } SCtgTbCache;