From 64a54c15419d63a8a3220d6aee73d3cf3ec5d865 Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Thu, 12 May 2022 19:57:17 +0800 Subject: [PATCH] fix bug --- source/libs/scalar/src/filter.c | 5 +++++ source/libs/scalar/src/scalar.c | 1 + 2 files changed, 6 insertions(+) diff --git a/source/libs/scalar/src/filter.c b/source/libs/scalar/src/filter.c index 91ecef6161..4317ad325e 100644 --- a/source/libs/scalar/src/filter.c +++ b/source/libs/scalar/src/filter.c @@ -3601,6 +3601,11 @@ EDealRes fltReviseRewriter(SNode** pNode, void* pContext) { return DEAL_RES_CONTINUE; } + if (FILTER_GET_FLAG(stat->info->options, FLT_OPTION_TIMESTAMP) && node->opType >= OP_TYPE_NOT_EQUAL) { + stat->scalarMode = true; + return DEAL_RES_CONTINUE; + } + if (NULL == node->pRight) { if (scalarGetOperatorParamNum(node->opType) > 1) { fltError("invalid operator, pRight:%p, nodeType:%d, opType:%d", node->pRight, nodeType(node), node->opType); diff --git a/source/libs/scalar/src/scalar.c b/source/libs/scalar/src/scalar.c index c63f0a27db..d7cac69d26 100644 --- a/source/libs/scalar/src/scalar.c +++ b/source/libs/scalar/src/scalar.c @@ -8,6 +8,7 @@ #include "tdatablock.h" #include "scalar.h" #include "tudf.h" +#include "ttime.h" int32_t scalarGetOperatorParamNum(EOperatorType type) { if (OP_TYPE_IS_NULL == type || OP_TYPE_IS_NOT_NULL == type || OP_TYPE_IS_TRUE == type || OP_TYPE_IS_NOT_TRUE == type -- GitLab