fix: fix address sanitizer error
This commit is contained in:
parent
cabe04fccd
commit
c882f4ba08
|
@ -863,10 +863,12 @@ static int32_t mndProcessCreateStreamReq(SRpcMsg *pReq) {
|
||||||
SName name = {0};
|
SName name = {0};
|
||||||
tNameFromString(&name, createStreamReq.name, T_NAME_ACCT | T_NAME_DB);
|
tNameFromString(&name, createStreamReq.name, T_NAME_ACCT | T_NAME_DB);
|
||||||
//reuse this function for stream
|
//reuse this function for stream
|
||||||
|
|
||||||
auditRecord1(pReq, pMnode->clusterId, "createStream", name.dbname, "",
|
//TODO
|
||||||
createStreamReq.sql, strlen(createStreamReq.sql));
|
if (createStreamReq.sql != NULL) {
|
||||||
|
auditRecord1(pReq, pMnode->clusterId, "createStream", name.dbname, "",
|
||||||
|
createStreamReq.sql, strlen(createStreamReq.sql));
|
||||||
|
}
|
||||||
_OVER:
|
_OVER:
|
||||||
if (code != 0 && code != TSDB_CODE_ACTION_IN_PROGRESS) {
|
if (code != 0 && code != TSDB_CODE_ACTION_IN_PROGRESS) {
|
||||||
mError("stream:%s, failed to create since %s", createStreamReq.name, terrstr());
|
mError("stream:%s, failed to create since %s", createStreamReq.name, terrstr());
|
||||||
|
|
Loading…
Reference in New Issue