diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/SubqueryToApply.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/SubqueryToApply.java
index 4165a9d0516948..c0a62e0c991aee 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/SubqueryToApply.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/SubqueryToApply.java
@@ -46,8 +46,8 @@
 import org.apache.doris.nereids.trees.expressions.functions.agg.NotNullableAggregateFunction;
 import org.apache.doris.nereids.trees.expressions.functions.scalar.AssertTrue;
 import org.apache.doris.nereids.trees.expressions.functions.scalar.Nvl;
+import org.apache.doris.nereids.trees.expressions.literal.BigIntLiteral;
 import org.apache.doris.nereids.trees.expressions.literal.BooleanLiteral;
-import org.apache.doris.nereids.trees.expressions.literal.IntegerLiteral;
 import org.apache.doris.nereids.trees.expressions.literal.VarcharLiteral;
 import org.apache.doris.nereids.trees.expressions.visitor.DefaultExpressionRewriter;
 import org.apache.doris.nereids.trees.plans.Plan;
@@ -499,7 +499,7 @@ private Pair<LogicalPlan, Optional<Expression>> addApply(SubqueryExpr subquery,
                     upperProjects.addAll(projects.build());
                     projects.add(new Alias(new AssertTrue(
                             ExpressionUtils.or(new IsNull(countSlot),
-                                    new LessThanEqual(countSlot, new IntegerLiteral(1))),
+                                    new LessThanEqual(countSlot, new BigIntLiteral(1))),
                             new VarcharLiteral("correlate scalar subquery must return only 1 row"))));
                     logicalProject = new LogicalProject(projects.build(), newApply);
                 } else {
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/ExistsApplyToJoin.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/ExistsApplyToJoin.java
index 683833248560e0..3d3527c76dc57b 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/ExistsApplyToJoin.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/ExistsApplyToJoin.java
@@ -24,7 +24,7 @@
 import org.apache.doris.nereids.trees.expressions.EqualTo;
 import org.apache.doris.nereids.trees.expressions.Expression;
 import org.apache.doris.nereids.trees.expressions.functions.agg.Count;
-import org.apache.doris.nereids.trees.expressions.literal.IntegerLiteral;
+import org.apache.doris.nereids.trees.expressions.literal.BigIntLiteral;
 import org.apache.doris.nereids.trees.plans.DistributeType;
 import org.apache.doris.nereids.trees.plans.JoinType;
 import org.apache.doris.nereids.trees.plans.LimitPhase;
@@ -127,7 +127,7 @@ private Plan unCorrelatedNotExist(LogicalApply<?, ?> unapply) {
                 unapply.getMarkJoinSlotReference(),
                 (LogicalPlan) unapply.left(), newAgg, null);
         return new LogicalFilter<>(ImmutableSet.of(new EqualTo(newAgg.getOutput().get(0),
-                new IntegerLiteral(0))), newJoin);
+                new BigIntLiteral(0))), newJoin);
     }
 
     private Plan unCorrelatedExist(LogicalApply<?, ?> unapply) {