diff --git a/source/libs/executor/src/filloperator.c b/source/libs/executor/src/filloperator.c
index 0ddf74437c4f2ab20ec907db7c2e80af2cd100df..80c88a803effb72588097c4b86acd808dde78354 100644
--- a/source/libs/executor/src/filloperator.c
+++ b/source/libs/executor/src/filloperator.c
@@ -1521,11 +1521,11 @@ SOperatorInfo* createStreamFillOperatorInfo(SOperatorInfo* downstream, SStreamFi
         float v = 0;
         GET_TYPED_DATA(v, float, pVar->nType, &pVar->i);
         SET_TYPED_DATA(pCell->pData, pCell->type, v);
-      } else if (pCell->type == TSDB_DATA_TYPE_DOUBLE) {
+      } else if (IS_FLOAT_TYPE(pCell->type)) {
         double v = 0;
         GET_TYPED_DATA(v, double, pVar->nType, &pVar->i);
         SET_TYPED_DATA(pCell->pData, pCell->type, v);
-      } else if (IS_SIGNED_NUMERIC_TYPE(pCell->type)) {
+      } else if (IS_INTEGER_TYPE(pCell->type)) {
         int64_t v = 0;
         GET_TYPED_DATA(v, int64_t, pVar->nType, &pVar->i);
         SET_TYPED_DATA(pCell->pData, pCell->type, v);