fix

924060929 · Aug 21, 2024 · aeb3fc5 · aeb3fc5
1 parent 5585073
commit aeb3fc5
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 4 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/SlotBinder.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/SlotBinder.java
@@ -119,7 +119,9 @@ public Expression visitUnboundVariable(UnboundVariable unboundVariable, Cascades
                 throw new AnalysisException(e.getMessage());
             }
         }
-        context.getStatementContext().hasUnsupportedSqlCacheExpression = true;
+        if (context != null) {
+            context.getStatementContext().hasUnsupportedSqlCacheExpression = true;
+        }
         return new Variable(unboundVariable.getName(), unboundVariable.getType(), literal);
     }
 

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
@@ -115,7 +115,9 @@ public Expression visitUnboundFunction(UnboundFunction unboundFunction, Expressi
         FunctionBuilder builder = functionRegistry.findFunctionBuilder(
                 unboundFunction.getDbName(), functionName, arguments);
         if (builder instanceof AliasUdfBuilder) {
-            context.cascadesContext.getStatementContext().hasUnsupportedSqlCacheExpression = true;
+            if (context != null) {
+                context.cascadesContext.getStatementContext().hasUnsupportedSqlCacheExpression = true;
+            }
             // we do type coercion in build function in alias function, so it's ok to return directly.
             return builder.build(functionName, arguments);
         } else {
@@ -133,7 +135,7 @@ public Expression visitUnboundFunction(UnboundFunction unboundFunction, Expressi
                 // 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 (boundFunction instanceof Nondeterministic) {
+            if (context != null && boundFunction instanceof Nondeterministic) {
                 context.cascadesContext.getStatementContext().hasUnsupportedSqlCacheExpression = true;
             }
             return boundFunction;

diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/cache/CacheAnalyzer.java b/fe/fe-core/src/main/java/org/apache/doris/qe/cache/CacheAnalyzer.java
@@ -344,7 +344,7 @@ private CacheMode innerCheckCacheModeForNereids(long now) {
             }
             return CacheMode.NoNeed;
         }
-        if (context.getStatementContext().hasUnsupportedSqlCacheExpression) {
+        if (context != null && context.getStatementContext().hasUnsupportedSqlCacheExpression) {
             return CacheMode.None;
         }
         if (!(parsedStmt instanceof LogicalPlanAdapter) || scanNodes.size() == 0) {