diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java index b1d6d877e8..0347964352 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java @@ -3260,7 +3260,7 @@ public class SessionVariable implements Serializable, Writable { tResult.setInvertedIndexConjunctionOptThreshold(invertedIndexConjunctionOptThreshold); tResult.setInvertedIndexMaxExpansions(invertedIndexMaxExpansions); - tResult.setEnableDecimal256(enableNereidsPlanner && enableDecimal256); + tResult.setEnableDecimal256(getEnableDecimal256()); tResult.setSkipMissingVersion(skipMissingVersion); @@ -3654,7 +3654,7 @@ public class SessionVariable implements Serializable, Writable { return false; } SessionVariable sessionVariable = connectContext.getSessionVariable(); - return sessionVariable.isEnableNereidsPlanner() && sessionVariable.isEnableDecimal256(); + return connectContext.getState().isNereids() && sessionVariable.isEnableDecimal256(); } public boolean isEnableDecimal256() {