From 00d374358a42a721cb7f4c8c84f7992ee39476c1 Mon Sep 17 00:00:00 2001
From: xsren <285808407@qq.com>
Date: Wed, 23 Oct 2024 11:38:46 +0800
Subject: [PATCH] fix: rowSize check

---
 source/libs/executor/src/dataDispatcher.c | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/source/libs/executor/src/dataDispatcher.c b/source/libs/executor/src/dataDispatcher.c
index b7422d849c..732b2566a9 100644
--- a/source/libs/executor/src/dataDispatcher.c
+++ b/source/libs/executor/src/dataDispatcher.c
@@ -63,7 +63,7 @@ static int32_t inputSafetyCheck(SDataDispatchHandle* pHandle, const SInputData*
     return TSDB_CODE_QRY_INVALID_INPUT;
   }
   SDataBlockDescNode* pSchema = pHandle->pSchema;
-  if (pSchema == NULL || pSchema->outputRowSize > pInput->pData->info.rowSize) {
+  if (pSchema == NULL || pSchema->totalRowSize != pInput->pData->info.rowSize) {
     qError("invalid schema");
     return TSDB_CODE_QRY_INVALID_INPUT;
   }
@@ -77,6 +77,7 @@ static int32_t inputSafetyCheck(SDataDispatchHandle* pHandle, const SInputData*
       realOutputRowSize += pSlotDesc->dataType.bytes;
       ++numOfCols;
     } else {
+      // Slots must be sorted, and slots with 'output' set to true must come first
       break;
     }
   }