diff --git a/source/libs/executor/inc/executorimpl.h b/source/libs/executor/inc/executorimpl.h index 00f2e09e0c..9d77c9badd 100644 --- a/source/libs/executor/inc/executorimpl.h +++ b/source/libs/executor/inc/executorimpl.h @@ -240,7 +240,7 @@ typedef struct SColMatchInfo { int32_t srcSlotId; // source slot id int32_t colId; int32_t targetSlotId; - bool output; + bool output; // todo remove this? bool reserved; int32_t matchType; // determinate the source according to col id or slot id } SColMatchInfo; diff --git a/source/libs/executor/src/executil.c b/source/libs/executor/src/executil.c index 24eae225bf..fcdc4c840e 100644 --- a/source/libs/executor/src/executil.c +++ b/source/libs/executor/src/executil.c @@ -700,7 +700,7 @@ void relocateColumnData(SSDataBlock* pBlock, const SArray* pColMatchInfo, SArray while (i < numOfSrcCols && j < taosArrayGetSize(pColMatchInfo)) { SColumnInfoData* p = taosArrayGet(pCols, i); SColMatchInfo* pmInfo = taosArrayGet(pColMatchInfo, j); - if (!outputEveryColumn && !pmInfo->output) { + if (!outputEveryColumn && pmInfo->reserved) { j++; continue; }