commit
2a8fe122c2
|
@ -349,6 +349,7 @@ int32_t streamSearchAndAddBlock(SStreamTask* pTask, SStreamDispatchReq* pReqs, S
|
||||||
SBlockName* pBln = (SBlockName*)pVal;
|
SBlockName* pBln = (SBlockName*)pVal;
|
||||||
hashValue = pBln->hashValue;
|
hashValue = pBln->hashValue;
|
||||||
if (!pDataBlock->info.parTbName[0]) {
|
if (!pDataBlock->info.parTbName[0]) {
|
||||||
|
memset(pDataBlock->info.parTbName, 0, TSDB_TABLE_NAME_LEN);
|
||||||
memcpy(pDataBlock->info.parTbName, pBln->parTbName, strlen(pBln->parTbName));
|
memcpy(pDataBlock->info.parTbName, pBln->parTbName, strlen(pBln->parTbName));
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
|
|
Loading…
Reference in New Issue