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

adj log

This commit is contained in:
54liuyao 2024-07-18 09:01:35 +08:00
parent 113cb57326
commit d5873aa1b2
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/libs/executor/src/streamtimewindowoperator.c
View File

@ -2352,7 +2352,7 @@ int32_t compactTimeWindow(SExprSupp* pSup, SStreamAggSupporter* pAggSup, STimeWi
TSDB_CHECK_CODE(code, lino, _end); TSDB_CHECK_CODE(code, lino, _end);
int32_t tmpRes = tSimpleHashRemove(pStUpdated, &pNextWin->sessionWin, sizeof(SSessionKey)); int32_t tmpRes = tSimpleHashRemove(pStUpdated, &pNextWin->sessionWin, sizeof(SSessionKey));
qTrace("%s at line %d res:%s", __func__, __LINE__, tmpRes); qTrace("%s at line %d res:%d", __func__, __LINE__, tmpRes);
if (pNextWin->isOutput && pStDeleted) { if (pNextWin->isOutput && pStDeleted) {
qDebug("===stream=== save delete window info %" PRId64 ", %" PRIu64, pNextWin->sessionWin.win.skey, qDebug("===stream=== save delete window info %" PRId64 ", %" PRIu64, pNextWin->sessionWin.win.skey,

10
source/libs/stream/src/tstreamFileState.c
View File

@ -484,9 +484,9 @@ _end:
void deleteRowBuff(SStreamFileState* pFileState, const void* pKey, int32_t keyLen) { void deleteRowBuff(SStreamFileState* pFileState, const void* pKey, int32_t keyLen) {
int32_t code_buff = pFileState->stateBuffRemoveFn(pFileState->rowStateBuff, pKey, keyLen); int32_t code_buff = pFileState->stateBuffRemoveFn(pFileState->rowStateBuff, pKey, keyLen);
qTrace("%s at line %d res:%s", __func__, __LINE__, code_buff); qTrace("%s at line %d res:%d", __func__, __LINE__, code_buff);
int32_t code_file = pFileState->stateFileRemoveFn(pFileState, pKey); int32_t code_file = pFileState->stateFileRemoveFn(pFileState, pKey);
qTrace("%s at line %d res:%s", __func__, __LINE__, code_file); qTrace("%s at line %d res:%d", __func__, __LINE__, code_file);
} }
int32_t resetRowBuff(SStreamFileState* pFileState, const void* pKey, int32_t keyLen) { int32_t resetRowBuff(SStreamFileState* pFileState, const void* pKey, int32_t keyLen) {
@ -682,7 +682,7 @@ int32_t deleteExpiredCheckPoint(SStreamFileState* pFileState, TSKEY mark) {
if (ts < mark) { if (ts < mark) {
// statekey winkey.ts < mark // statekey winkey.ts < mark
int32_t tmpRes = forceRemoveCheckpoint(pFileState, i); int32_t tmpRes = forceRemoveCheckpoint(pFileState, i);
qTrace("%s at line %d res:%s", __func__, __LINE__, tmpRes); qTrace("%s at line %d res:%d", __func__, __LINE__, tmpRes);
break; break;
} }
} }
@ -696,7 +696,7 @@ void recoverSesssion(SStreamFileState* pFileState, int64_t ckId) {
? INT64_MIN ? INT64_MIN
: pFileState->maxTs - pFileState->deleteMark; : pFileState->maxTs - pFileState->deleteMark;
int32_t tmpRes = deleteExpiredCheckPoint(pFileState, mark); int32_t tmpRes = deleteExpiredCheckPoint(pFileState, mark);
qTrace("%s at line %d res:%s", __func__, __LINE__, tmpRes); qTrace("%s at line %d res:%d", __func__, __LINE__, tmpRes);
} }
SStreamStateCur* pCur = streamStateSessionSeekToLast_rocksdb(pFileState->pFileStore, INT64_MAX); SStreamStateCur* pCur = streamStateSessionSeekToLast_rocksdb(pFileState->pFileStore, INT64_MAX);
@ -731,7 +731,7 @@ void recoverSnapshot(SStreamFileState* pFileState, int64_t ckId) {
? INT64_MIN ? INT64_MIN
: pFileState->maxTs - pFileState->deleteMark; : pFileState->maxTs - pFileState->deleteMark;
int32_t tmpRes = deleteExpiredCheckPoint(pFileState, mark); int32_t tmpRes = deleteExpiredCheckPoint(pFileState, mark);
qTrace("%s at line %d res:%s", __func__, __LINE__, tmpRes); qTrace("%s at line %d res:%d", __func__, __LINE__, tmpRes);
} }
SStreamStateCur* pCur = streamStateSeekToLast_rocksdb(pFileState->pFileStore); SStreamStateCur* pCur = streamStateSeekToLast_rocksdb(pFileState->pFileStore);