fix(query): fix invalid read for interp query

74c40f01 · Ganlin Zhao · e7fbada3 · 74c40f01
隐藏空白更改
内联并排

Showing with 10 addition and 2 deletion

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

未找到文件。
--- a/source/libs/executor/src/timewindowoperator.c
+++ b/source/libs/executor/src/timewindowoperator.c
@@ -2015,7 +2015,11 @@ static void doKeepPrevRows(STimeSliceOperatorInfo* pSliceInfo, const SSDataBlock
      pkey->isNull = false;
      char* val = colDataGetData(pColInfoData, rowIndex);
-      memcpy(pkey->pData, val, pkey->bytes);
+      if (!IS_VAR_DATA_TYPE(pkey->type)) {
+        memcpy(pkey->pData, val, pkey->bytes);
+      } else {
+        memcpy(pkey->pData, val, varDataLen(val));
+      }
    }
  }
@@ -2033,7 +2037,11 @@ static void doKeepNextRows(STimeSliceOperatorInfo* pSliceInfo, const SSDataBlock
      pkey->isNull = false;
      char* val = colDataGetData(pColInfoData, rowIndex);
-      memcpy(pkey->pData, val, pkey->bytes);
+      if (!IS_VAR_DATA_TYPE(pkey->type)) {
+        memcpy(pkey->pData, val, pkey->bytes);
+      } else {
+        memcpy(pkey->pData, val, varDataLen(val));
+      }
    }
  }