From d5873aa1b29cd8571a88185bad025545fa7fb8ec Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao>
Date: Thu, 18 Jul 2024 09:01:35 +0800
Subject: [PATCH] adj log

---
 source/libs/executor/src/streamtimewindowoperator.c |  2 +-
 source/libs/stream/src/tstreamFileState.c           | 10 +++++-----
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/source/libs/executor/src/streamtimewindowoperator.c b/source/libs/executor/src/streamtimewindowoperator.c
index 1ee6270677..60beea0876 100644
--- a/source/libs/executor/src/streamtimewindowoperator.c
+++ b/source/libs/executor/src/streamtimewindowoperator.c
@@ -2352,7 +2352,7 @@ int32_t compactTimeWindow(SExprSupp* pSup, SStreamAggSupporter* pAggSup, STimeWi
   TSDB_CHECK_CODE(code, lino, _end);
 
   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) {
     qDebug("===stream=== save delete window info %" PRId64 ", %" PRIu64, pNextWin->sessionWin.win.skey,
diff --git a/source/libs/stream/src/tstreamFileState.c b/source/libs/stream/src/tstreamFileState.c
index 7f8892e961..f682673dc0 100644
--- a/source/libs/stream/src/tstreamFileState.c
+++ b/source/libs/stream/src/tstreamFileState.c
@@ -484,9 +484,9 @@ _end:
 
 void deleteRowBuff(SStreamFileState* pFileState, const void* pKey, int32_t 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);
-  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) {
@@ -682,7 +682,7 @@ int32_t deleteExpiredCheckPoint(SStreamFileState* pFileState, TSKEY mark) {
     if (ts < mark) {
       // statekey winkey.ts < mark
       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;
     }
   }
@@ -696,7 +696,7 @@ void recoverSesssion(SStreamFileState* pFileState, int64_t ckId) {
                        ? INT64_MIN
                        : pFileState->maxTs - pFileState->deleteMark;
     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);
@@ -731,7 +731,7 @@ void recoverSnapshot(SStreamFileState* pFileState, int64_t ckId) {
                        ? INT64_MIN
                        : pFileState->maxTs - pFileState->deleteMark;
     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);