diff --git a/source/libs/executor/src/tsort.c b/source/libs/executor/src/tsort.c
index b3f342c694..261ab2b2e8 100644
--- a/source/libs/executor/src/tsort.c
+++ b/source/libs/executor/src/tsort.c
@@ -121,10 +121,12 @@ void tsortClearOrderdSource(SArray* pOrderedSource) {
     if ((*pSource)->param && !(*pSource)->onlyRef) {
       taosMemoryFree((*pSource)->param);
     }
-    if ((*pSource)->src.pBlock) {
+
+    if (!(*pSource)->onlyRef && (*pSource)->src.pBlock) {
       blockDataDestroy((*pSource)->src.pBlock);
       (*pSource)->src.pBlock = NULL;
     }
+
     taosMemoryFreeClear(*pSource);
   }