fear(stream): add log

d9615c7d · 54liuyao · bb490f07 · d9615c7d
隐藏空白更改
内联并排

Showing with 2 addition and 1 deletion

source/libs/executor/src/timewindowoperator.c source/libs/executor/src/timewindowoperator.c +2 -1

未找到文件。
--- a/source/libs/executor/src/timewindowoperator.c
+++ b/source/libs/executor/src/timewindowoperator.c
@@ -1541,7 +1541,8 @@ static void deleteIntervalDiscBuf(SStreamState* pState, SHashObj* pPullDataMap,
    }
  }

-  if (qDebugFlag & DEBUG_DEBUG) {
+  // for debug
+  if (qDebugFlag & DEBUG_DEBUG && mark > 0) {
    SStreamStateCur* pCur = streamStateGetCur(pState, key);
    int32_t          code = streamStateCurPrev(pState, pCur);
    if (code == TSDB_CODE_SUCCESS) {