fix(stream): fix syntax error.
This commit is contained in:
parent
28df9fe285
commit
3821f88e64
|
@ -582,9 +582,8 @@ int32_t doSendCheckMsg(SStreamTask* pTask, SDownstreamStatusInfo* p) {
|
|||
|
||||
if (code) {
|
||||
stError("s-task:%s failed to send check msg to downstream, code:%s", pTask->id.idStr, tstrerror(code));
|
||||
} else {
|
||||
return code;
|
||||
}
|
||||
return code;
|
||||
}
|
||||
|
||||
void getCheckRspStatus(STaskCheckInfo* pInfo, int64_t el, int32_t* numOfReady, int32_t* numOfFault,
|
||||
|
|
Loading…
Reference in New Issue