fix(stream): update logs.
This commit is contained in:
parent
6cc3b5da0e
commit
963e397984
|
@ -422,7 +422,7 @@ static int32_t doBuildAndSendCreateTableMsg(SVnode* pVnode, char* stbFullName, S
|
||||||
reqs.nReqs = taosArrayGetSize(reqs.pArray);
|
reqs.nReqs = taosArrayGetSize(reqs.pArray);
|
||||||
code = tqPutReqToQueue(pVnode, &reqs, encodeCreateChildTableForRPC, TDMT_VND_CREATE_TABLE);
|
code = tqPutReqToQueue(pVnode, &reqs, encodeCreateChildTableForRPC, TDMT_VND_CREATE_TABLE);
|
||||||
if (code != TSDB_CODE_SUCCESS) {
|
if (code != TSDB_CODE_SUCCESS) {
|
||||||
tqError("s-task:%s failed to send create table msg", id);
|
tqError("s-task:%s failed to send create table msg, code:%s", id, tstrerror(code));
|
||||||
}
|
}
|
||||||
|
|
||||||
_end:
|
_end:
|
||||||
|
|
Loading…
Reference in New Issue