diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/BinaryPredicate.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/BinaryPredicate.java
index f9bd72e3f7..d2a9a1825a 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/BinaryPredicate.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/BinaryPredicate.java
@@ -492,17 +492,24 @@ public class BinaryPredicate extends Predicate implements Writable {
             }
         }
 
-        if ((t1.isDecimalV3Type() && !t2.isStringType() && !t2.isFloatingPointType())
-                || (t2.isDecimalV3Type() && !t1.isStringType() && !t1.isFloatingPointType())) {
+        if ((t1.isDecimalV3Type() && !t2.isStringType() && !t2.isFloatingPointType() && !t2.isVariantType())
+                || (t2.isDecimalV3Type() && !t1.isStringType() && !t1.isFloatingPointType() && !t1.isVariantType())) {
             return Type.getAssignmentCompatibleType(getChild(0).getType(), getChild(1).getType(), false,
                     SessionVariable.getEnableDecimal256());
         }
 
         // Variant can be implicit cast to numeric type and string type at present
         if (t1.isVariantType() && (t2.isNumericType() || t2.isStringType())) {
+            if (t2.isDecimalV2Type() || t2.isDecimalV3Type()) {
+                // TODO support decimal
+                return Type.DOUBLE;
+            }
             return Type.fromPrimitiveType(t2);
         }
         if (t2.isVariantType() && (t1.isNumericType() || t1.isStringType())) {
+            if (t1.isDecimalV2Type() || t1.isDecimalV3Type()) {
+                return Type.DOUBLE;
+            }
             return Type.fromPrimitiveType(t1);
         }
 
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/ExpressionAnalyzer.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/ExpressionAnalyzer.java
index dbdf817ef6..f4c1b428d4 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/ExpressionAnalyzer.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/ExpressionAnalyzer.java
@@ -114,6 +114,12 @@ public class ExpressionAnalyzer extends SubExprAnalyzer<ExpressionRewriteContext
     private final boolean bindSlotInOuterScope;
     private boolean currentInLambda;
 
+    // Keep track of which element_at function's level
+    // e.g. element_at(element_at(v, 'repo'), 'name') level 1
+    //      element_at(v, 'repo') level 2
+    // Only works with function ElementAt which satisfy condition PushDownToProjectionFunction.validToPushDown
+    private int currentElementAtLevel = 0;
+
     public ExpressionAnalyzer(Plan currentPlan, Scope scope, CascadesContext cascadesContext,
             boolean enableExactMatch, boolean bindSlotInOuterScope) {
         super(scope, cascadesContext);
@@ -285,6 +291,9 @@ public class ExpressionAnalyzer extends SubExprAnalyzer<ExpressionRewriteContext
      * ******************************************************************************************** */
     @Override
     public Expression visitUnboundFunction(UnboundFunction unboundFunction, ExpressionRewriteContext context) {
+        if (unboundFunction.getName().equalsIgnoreCase("element_at")) {
+            ++currentElementAtLevel;
+        }
         if (unboundFunction.isHighOrder()) {
             unboundFunction = bindHighOrderFunction(unboundFunction, context);
         } else {
@@ -331,6 +340,17 @@ public class ExpressionAnalyzer extends SubExprAnalyzer<ExpressionRewriteContext
                 // so wrap COUNT with Nvl to ensure it's result is 0 instead of null to get the correct result
                 boundFunction = new Nvl(boundFunction, new BigIntLiteral(0));
             }
+
+            if (currentElementAtLevel == 1
+                    && PushDownToProjectionFunction.validToPushDown(boundFunction)) {
+                // Only rewrite the top level of PushDownToProjectionFunction, otherwise invalid slot will be generated
+                // currentElementAtLevel == 1 means at the top of element_at function, other levels will be ignored.
+                currentElementAtLevel = 0;
+                return visitElementAt((ElementAt) boundFunction, context);
+            }
+            if (boundFunction instanceof ElementAt) {
+                --currentElementAtLevel;
+            }
             return boundFunction;
         }
     }
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/expression/rules/FunctionBinder.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/expression/rules/FunctionBinder.java
index bf0812cdc2..e8ed474a1b 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/expression/rules/FunctionBinder.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/expression/rules/FunctionBinder.java
@@ -80,6 +80,12 @@ public class FunctionBinder extends AbstractExpressionRewriteRule {
 
     public static final FunctionBinder INSTANCE = new FunctionBinder();
 
+    // Keep track of which element_at function's level
+    // e.g. element_at(element_at(v, 'repo'), 'name') level 1
+    //      element_at(v, 'repo') level 2
+    // Only works with function ElementAt which satisfy condition PushDownToProjectionFunction.validToPushDown
+    private int currentElementAtLevel = 0;
+
     @Override
     public Expression visit(Expression expr, ExpressionRewriteContext context) {
         expr = super.visit(expr, context);
@@ -141,6 +147,9 @@ public class FunctionBinder extends AbstractExpressionRewriteRule {
 
     @Override
     public Expression visitUnboundFunction(UnboundFunction unboundFunction, ExpressionRewriteContext context) {
+        if (unboundFunction.getName().equalsIgnoreCase("element_at")) {
+            ++currentElementAtLevel;
+        }
         if (unboundFunction.isHighOrder()) {
             unboundFunction = bindHighOrderFunction(unboundFunction, context);
         } else {
@@ -188,6 +197,16 @@ public class FunctionBinder extends AbstractExpressionRewriteRule {
                 // so wrap COUNT with Nvl to ensure it's result is 0 instead of null to get the correct result
                 boundFunction = new Nvl(boundFunction, new BigIntLiteral(0));
             }
+            if (currentElementAtLevel == 1
+                    && PushDownToProjectionFunction.validToPushDown(boundFunction)) {
+                // Only rewrite the top level of PushDownToProjectionFunction, otherwise invalid slot will be generated
+                // currentElementAtLevel == 1 means at the top of element_at function, other levels will be ignored.
+                currentElementAtLevel = 0;
+                return visitElementAt((ElementAt) boundFunction, context);
+            }
+            if (boundFunction instanceof ElementAt) {
+                --currentElementAtLevel;
+            }
             return boundFunction;
         }
     }
@@ -201,6 +220,7 @@ public class FunctionBinder extends AbstractExpressionRewriteRule {
     @Override
     public Expression visitElementAt(ElementAt elementAt, ExpressionRewriteContext context) {
         Expression boundFunction = visitBoundFunction(elementAt, context);
+
         if (PushDownToProjectionFunction.validToPushDown(boundFunction)) {
             if (ConnectContext.get() != null
                     && ConnectContext.get().getSessionVariable() != null
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/util/TypeCoercionUtils.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/util/TypeCoercionUtils.java
index a953122d46..e2b183cde4 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/nereids/util/TypeCoercionUtils.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/util/TypeCoercionUtils.java
@@ -1294,9 +1294,17 @@ public class TypeCoercionUtils {
 
         // variant type
         if ((leftType.isVariantType() && (rightType.isStringLikeType() || rightType.isNumericType()))) {
+            if (rightType.isDecimalLikeType()) {
+                // TODO support decimal
+                return Optional.of(DoubleType.INSTANCE);
+            }
             return Optional.of(rightType);
         }
         if ((rightType.isVariantType() && (leftType.isStringLikeType() || leftType.isNumericType()))) {
+            if (leftType.isDecimalLikeType()) {
+                // TODO support decimal
+                return Optional.of(DoubleType.INSTANCE);
+            }
             return Optional.of(leftType);
         }
         return Optional.of(DoubleType.INSTANCE);
diff --git a/regression-test/data/variant_p0/view.out b/regression-test/data/variant_p0/view.out
new file mode 100644
index 0000000000..b3e7b99386
--- /dev/null
+++ b/regression-test/data/variant_p0/view.out
@@ -0,0 +1,63 @@
+-- This file is automatically generated. You should know what you did if you want to edit this
+-- !sql --
+prakhar1989/awesome-courses	6
+Anchor89/GithubHub	4
+imgix/imgix-emacs	4
+isohuntto/openbay	4
+kragniz/json-sempai	4
+
+-- !sql --
+vangdfang/libcutter	4.0	4	1
+GijsTimmers/kotnetcli	2.0	2	1
+Jamesking56/Cachet	2.0	2	1
+WasabiFan/ev3dev.github.io	2.0	2	1
+kripken/emscripten-fastcomp-clang	2.0	2	1
+kyrias/pkgbuilds	1.0	2	2
+rene-scheepers/case-life	2.0	2	1
+Arctium/Arctium-WoW	1.0	1	1
+Gankro/rust	1.0	1	1
+GoldenLions/GitHubScout	1.0	1	1
+LynxEffect/Africa18Tumblr	1.0	1	1
+NREL/EnergyPlus	1.0	1	1
+NREL/OpenStudio	1.0	1	1
+PCSX2/pcsx2	1.0	1	1
+Rythal/Carbonite	1.0	1	1
+SemanticMediaWiki/SemanticMediaWiki	1.0	1	1
+ahungry/web-mode	1.0	1	1
+alexcrichton/rust	1.0	1	1
+alexrj/Slic3r	1.0	1	1
+botandrose/calagator	1.0	1	1
+dcrewi/rust	1.0	1	1
+dualspiral/BungeeCord	1.0	1	1
+fhgwright/osxfuse	1.0	1	1
+gssiyankai/javaewah	1.0	1	1
+hmody26/-	1.0	1	1
+hrydgard/ppsspp	1.0	1	1
+japaric/rust	1.0	1	1
+matghaleb/offline	1.0	1	1
+mpv-player/mpv	1.0	1	1
+nikomatsakis/rust	1.0	1	1
+officeroftheday/recipes	1.0	1	1
+pogostick29dev/BanManagement-Bukkit	1.0	1	1
+rom-rb/rom	1.0	1	1
+rust-lang/rust	1.0	1	1
+samp-incognito/samp-streamer-plugin	1.0	1	1
+shurcooL/Conception-go	1.0	1	1
+twbs/bootstrap	1.0	1	1
+we555/hello-world	1.0	1	1
+xbianonpi/btrfs-tools	1.0	1	1
+xbianonpi/qemu-env	1.0	1	1
+xbianonpi/skin.amber	1.0	1	1
+xbianonpi/xbian-config-bash	1.0	1	1
+xbianonpi/xbian-package-download	1.0	1	1
+xbianonpi/xbian-package-libshairport	1.0	1	1
+xbianonpi/xbian-package-libtag	1.0	1	1
+xbianonpi/xbian-package-samba	1.0	1	1
+xbianonpi/xbian-xbmc-repository	1.0	1	1
+
+-- !sql --
+3648
+
+-- !sql --
+apache/doris	12345
+
diff --git a/regression-test/suites/variant_p0/view.groovy b/regression-test/suites/variant_p0/view.groovy
new file mode 100644
index 0000000000..c07b93e588
--- /dev/null
+++ b/regression-test/suites/variant_p0/view.groovy
@@ -0,0 +1,83 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+suite("regression_test_variant_view", "var_view") {
+    def load_json_data = {table_name, file_name ->
+        // load the json data
+        streamLoad {
+            table "${table_name}"
+
+            // set http request header params
+            set 'read_json_by_line', 'true' 
+            set 'format', 'json' 
+            set 'max_filter_ratio', '0.1'
+            file file_name // import json file
+            time 10000 // limit inflight 10s
+
+            // if declared a check callback, the default check condition will ignore.
+            // So you must check all condition
+
+            check { result, exception, startTime, endTime ->
+                if (exception != null) {
+                        throw exception
+                }
+                logger.info("Stream load ${file_name} result: ${result}".toString())
+                def json = parseJson(result)
+                assertEquals("success", json.Status.toLowerCase())
+                // assertEquals(json.NumberTotalRows, json.NumberLoadedRows + json.NumberUnselectedRows)
+                assertTrue(json.NumberLoadedRows > 0 && json.LoadBytes > 0)
+            }
+        }
+    }
+    sql """DROP TABLE IF EXISTS github_events_view"""
+    sql """
+        CREATE TABLE IF NOT EXISTS github_events_view (
+            k bigint,
+            v variant
+        )
+        UNIQUE KEY(`k`)
+        DISTRIBUTED BY HASH(k) BUCKETS 4
+        properties("replication_num" = "1", "disable_auto_compaction" = "true");
+    """
+    load_json_data.call("github_events_view", """${getS3Url() + '/regression/gharchive.m/2015-01-01-0.json'}""")
+    sql " drop view if exists v1"
+    sql """create view v1 as SELECT cast(v["repo"]["name"] as string) as repo_name, count() AS stars FROM github_events_view WHERE cast(v["type"] as string) = 'WatchEvent' GROUP BY repo_name  ORDER BY stars DESC, repo_name LIMIT 5;"""
+    qt_sql """select * from v1"""
+    sql " drop view if exists v2"
+    sql """create view v2 as SELECT
+            cast(v["repo"]["name"] as string) as repo_name,
+            count() AS comments,
+            count(distinct cast(v["actor"]["login"] as string)) AS authors
+            FROM github_events_view 
+            WHERE cast(v["type"] as string) = 'CommitCommentEvent'
+            GROUP BY repo_name 
+            ORDER BY count() DESC, 1, 3
+            LIMIT 50
+    """
+    qt_sql """select repo_name, comments/authors, comments, authors  from v2;"""
+    sql "drop view if exists v3"
+    sql """create view v3 as SELECT
+            count(distinct(cast(v["actor"]["login"] as string))) AS authors
+            FROM github_events_view
+    """
+    qt_sql "select * from v3"
+
+    sql "drop view if exists v4"
+    sql """insert into github_events_view values (1, '{"ratio" : 1.1, "repo" : {"name" : "apache/doris", "id" : 12345}}')"""
+    sql """create view v4 as SELECT cast(v["repo"]["name"] as string) repo_name,  cast(v["repo"]["id"] as int) as id from github_events_view where v['ratio'] > 0.7"""
+    qt_sql """select * from v4"""
+}
\ No newline at end of file