From eabfc7d31cf38134d405bcc6c33adaffc50d91a4 Mon Sep 17 00:00:00 2001
From: Ganlin Zhao <36554565+glzhao89@users.noreply.github.com>
Date: Wed, 13 Apr 2022 12:38:57 +0800
Subject: [PATCH] feat(query): add timediff function

TD-14243
---
 source/libs/scalar/src/sclfunc.c | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/source/libs/scalar/src/sclfunc.c b/source/libs/scalar/src/sclfunc.c
index 76059cf2e1..db62a6b33d 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;
+        }
       }
     }
 
-- 
GitLab