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

fix stream backend convert

This commit is contained in:
yihaoDeng 2023-11-16 17:35:17 +08:00
parent 8023f2bebd
commit 7905f22aae
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -202,7 +202,8 @@ STREAM_ENCODE_OVER:
return NULL; return NULL;
} }
mTrace("stream:%s, encode to raw:%p, row:%p", pStream->name, pRaw, pStream); mTrace("stream:%s, encode to raw:%p, row:%p, checkpoint:%" PRId64 "", pStream->name, pRaw, pStream,
pStream->checkpointId);
return pRaw; return pRaw;
} }
@ -255,7 +256,8 @@ STREAM_DECODE_OVER:
return NULL; return NULL;
} }
mTrace("stream:%s, decode from raw:%p, row:%p", pStream->name, pRaw, pStream); mTrace("stream:%s, decode from raw:%p, row:%p, checkpoint:%" PRId64 "", pStream->name, pRaw, pStream,
pStream->checkpointId);
return pRow; return pRow;
} }
@ -908,8 +910,11 @@ int64_t mndStreamGenChkpId(SMnode *pMnode) {
if (pIter == NULL) break; if (pIter == NULL) break;
maxChkpId = TMAX(maxChkpId, pStream->checkpointId); maxChkpId = TMAX(maxChkpId, pStream->checkpointId);
mError("stream %p checkpoint %" PRId64 "", pStream, pStream->checkpointId);
sdbRelease(pSdb, pStream); sdbRelease(pSdb, pStream);
} }
mError("generated checkpoint %" PRId64 "", maxChkpId + 1);
return maxChkpId + 1; return maxChkpId + 1;
} }