fix(stream): add some logs.

2023-09-22 18:56:31 +08:00 · 2023-09-22 18:56:31 +08:00 · e49409a11e
parent 5eee76df65
commit e49409a11e
1 changed files with 1 additions and 1 deletions
--- a/source/libs/stream/src/stream.c
+++ b/source/libs/stream/src/stream.c
@ -256,7 +256,7 @@ int32_t streamProcessDispatchMsg(SStreamTask* pTask, SStreamDispatchReq* pReq, S
    // do send response with the input status
    int32_t code = buildDispatchRsp(pTask, pReq, status, &pRsp->pCont);
    if (code != TSDB_CODE_SUCCESS) {
-      // todo handle failure
+      stError("s-task:%s failed to build dispatch rsp, msgId:%d, code:%s", pTask->id.idStr, pReq->msgId, tstrerror(code));
      return code;
    }