xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

other: fix syntax error.

This commit is contained in:
Haojun Liao 2024-06-11 11:12:24 +08:00
parent 50f6829894
commit 68aac5dee1
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/dnode/mnode/impl/src/mndStream.c
View File

@ -2569,7 +2569,7 @@ int32_t mndProcessCheckpointReport(SRpcMsg *pReq) {
if (pStream != NULL) { if (pStream != NULL) {
bool conflict = mndStreamTransConflictCheck(pMnode, pStream->uid, MND_STREAM_CHKPT_UPDATE_NAME, false); bool conflict = mndStreamTransConflictCheck(pMnode, pStream->uid, MND_STREAM_CHKPT_UPDATE_NAME, false);
if (conflict) { if (conflict) {
mDebug("stream:%x%"PRIx64" active checkpoint trans not finished yet, wait", req.streamId); mDebug("stream:0x%"PRIx64" active checkpoint trans not finished yet, wait", req.streamId);
} else { } else {
int32_t code = mndCreateStreamChkptInfoUpdateTrans(pMnode, pStream, *pReqTaskList); int32_t code = mndCreateStreamChkptInfoUpdateTrans(pMnode, pStream, *pReqTaskList);
if (code == TSDB_CODE_SUCCESS) { // remove this entry if (code == TSDB_CODE_SUCCESS) { // remove this entry

2
source/dnode/mnode/impl/src/mndStreamUtil.c
View File

@ -789,7 +789,7 @@ void scanCheckpointReportInfo(SMnode* pMnode) {
pInfo->streamId); pInfo->streamId);
} }
} else { } else {
mDebug("stream:%x%"PRIx64" active checkpoint trans not finished yet, wait", pInfo->streamId); mDebug("stream:0x%"PRIx64" active checkpoint trans not finished yet, wait", pInfo->streamId);
} }
} else { } else {
mDebug("stream:0x%" PRIx64 " %s %d/%d tasks send checkpoint-report, %d not send", pInfo->streamId, pStream->name, mDebug("stream:0x%" PRIx64 " %s %d/%d tasks send checkpoint-report, %d not send", pInfo->streamId, pStream->name,