From fbf83d06a85273faf78c65d30a56eea0e5e768ad Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao@163.com>
Date: Tue, 2 Aug 2022 09:17:32 +0800
Subject: [PATCH] feat(stream): add log

---
 source/common/src/tdatablock.c | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/source/common/src/tdatablock.c b/source/common/src/tdatablock.c
index 7cfc1c0b1d..613fdd6b77 100644
--- a/source/common/src/tdatablock.c
+++ b/source/common/src/tdatablock.c
@@ -1725,6 +1725,7 @@ char* dumpBlockData(SSDataBlock* pDataBlock, const char* flag, char** pDataBuf)
       }
       switch (pColInfoData->info.type) {
         case TSDB_DATA_TYPE_TIMESTAMP:
+          memset(pBuf, 0, sizeof(pBuf));
           formatTimestamp(pBuf, *(uint64_t*)var, TSDB_TIME_PRECISION_MILLI);
           len += snprintf(dumpBuf + len, size - len, " %25s |", pBuf);
           if (len >= size - 1) return dumpBuf;
@@ -1753,6 +1754,18 @@ char* dumpBlockData(SSDataBlock* pDataBlock, const char* flag, char** pDataBuf)
           len += snprintf(dumpBuf + len, size - len, " %15lf |", *(double*)var);
           if (len >= size - 1) return dumpBuf;
           break;
+        case TSDB_DATA_TYPE_BOOL:
+          len += snprintf(dumpBuf + len, size - len, " %15d |", *(bool*)var);
+          if (len >= size - 1) return dumpBuf;
+          break;
+        case TSDB_DATA_TYPE_VARCHAR:
+        case TSDB_DATA_TYPE_NCHAR:
+          memset(pBuf, 0, sizeof(pBuf));
+          char* pData = colDataGetVarData(pColInfoData, j);
+          memcpy(pBuf, varDataVal(pData), varDataLen(pData));
+          len += snprintf(dumpBuf + len, size - len, " %15s |", pBuf);
+          if (len >= size - 1) return dumpBuf;
+          break;
       }
     }
     len += snprintf(dumpBuf + len, size - len, "\n");
-- 
GitLab