parent
5728685772
commit
aa4daf1770
|
@ -5954,6 +5954,7 @@ int32_t tDecodeSMqDataRsp(SDecoder *pDecoder, SMqDataRsp *pRsp) {
|
||||||
if (pSW == NULL) return -1;
|
if (pSW == NULL) return -1;
|
||||||
if (tDecodeSSchemaWrapper(pDecoder, pSW) < 0) return -1;
|
if (tDecodeSSchemaWrapper(pDecoder, pSW) < 0) return -1;
|
||||||
taosArrayPush(pRsp->blockSchema, &pSW);
|
taosArrayPush(pRsp->blockSchema, &pSW);
|
||||||
|
taosMemoryFree(pSW);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (pRsp->withTbName) {
|
if (pRsp->withTbName) {
|
||||||
|
|
Loading…
Reference in New Issue