diff --git a/source/libs/executor/src/streamtimewindowoperator.c b/source/libs/executor/src/streamtimewindowoperator.c
index 6e1cfd40f0..893848f010 100644
--- a/source/libs/executor/src/streamtimewindowoperator.c
+++ b/source/libs/executor/src/streamtimewindowoperator.c
@@ -3482,7 +3482,7 @@ void doStreamStateSaveCheckpoint(SOperatorInfo* pOperator) {
   len = doStreamStateEncodeOpState(&pBuf, len, pOperator, true);
   pInfo->streamAggSup.stateStore.streamStateSaveInfo(pInfo->streamAggSup.pState, STREAM_STATE_OP_CHECKPOINT_NAME,
                                                      strlen(STREAM_STATE_OP_CHECKPOINT_NAME), buf, len);
-  taosMemoryFree(pBuf);
+  taosMemoryFree(buf);
 }
 
 static SSDataBlock* buildStateResult(SOperatorInfo* pOperator) {