diff --git a/source/libs/scalar/src/sclfunc.c b/source/libs/scalar/src/sclfunc.c index 76059cf2e17b102592f0cf03d6ad020f6c27be6a..db62a6b33d6baaf60b4cc0c0fa0eda8bf641ef53 100644 --- a/source/libs/scalar/src/sclfunc.c +++ b/source/libs/scalar/src/sclfunc.c @@ -1168,10 +1168,12 @@ int32_t timeDiffFunction(SScalarParam *pInput, int32_t inputNum, SScalarParam *p } } - if (IS_VAR_DATA_TYPE(type)) { - input[k] += varDataTLen(input[k]); - } else { - input[k] += tDataTypes[type].bytes; + if (pInput[k].numOfRows != 1) { + if (IS_VAR_DATA_TYPE(type)) { + input[k] += varDataTLen(input[k]); + } else { + input[k] += tDataTypes[type].bytes; + } } }