diff --git a/include/common/tmsg.h b/include/common/tmsg.h index e714dc1522..325a428f03 100644 --- a/include/common/tmsg.h +++ b/include/common/tmsg.h @@ -670,7 +670,7 @@ typedef struct { static FORCE_INLINE SColCmprWrapper* tCloneSColCmprWrapper(const SColCmprWrapper* pSrcWrapper) { if (pSrcWrapper->pColCmpr == NULL || pSrcWrapper->nCols == 0) return NULL; - SColCmprWrapper* pDstWrapper = taosMemoryMalloc(pSrcWrapper->nCols * sizeof(SColCmpr)); + SColCmprWrapper* pDstWrapper = (SColCmprWrapper*)taosMemoryMalloc(sizeof(SColCmprWrapper)); pDstWrapper->nCols = pSrcWrapper->nCols; pDstWrapper->version = pSrcWrapper->version; diff --git a/source/util/test/decompressTest.cpp b/source/util/test/decompressTest.cpp index caf8df3ba8..2241be67fb 100644 --- a/source/util/test/decompressTest.cpp +++ b/source/util/test/decompressTest.cpp @@ -13,6 +13,7 @@ TEST(utilTest, decompress_test) { int32_t len = tsCompressTimestamp(tsList, sizeof(tsList), sizeof(tsList) / sizeof(tsList[0]), pOutput, 10, ONE_STAGE_COMP, NULL, 0); char* decompOutput[10 * 8] = {0}; + tsDecompressTimestamp(pOutput, len, 10, decompOutput, sizeof(int64_t)*10, ONE_STAGE_COMP, NULL, 0); for(int32_t i = 0; i < 10; ++i) {