branch-3.0: [fix](cache) fix sql cache throw npe in cloud mode #47221

fe/fe-core/src/main/java/org/apache/doris/common/NereidsSqlCacheManager.java

@@ -225,37 +225,36 @@ private String normalizeSql(String sql) {
     private Optional<LogicalSqlCache> tryParseSql(
             ConnectContext connectContext, String key, SqlCacheContext sqlCacheContext,
             UserIdentity currentUserIdentity, boolean checkUserVariable) {
-        Env env = connectContext.getEnv();
-
-        if (!tryLockTables(connectContext, env, sqlCacheContext)) {
-            return invalidateCache(key);
-        }
+        try {
+            Env env = connectContext.getEnv();
 
-        // check table and view and their columns authority
-        if (privilegeChanged(connectContext, env, sqlCacheContext)) {
-            return invalidateCache(key);
-        }
-        if (tablesOrDataChanged(env, sqlCacheContext)) {
-            return invalidateCache(key);
-        }
-        if (viewsChanged(env, sqlCacheContext)) {
-            return invalidateCache(key);
-        }
+            if (!tryLockTables(connectContext, env, sqlCacheContext)) {
+                return invalidateCache(key);
+            }
 
-        LogicalEmptyRelation whateverPlan = new LogicalEmptyRelation(new RelationId(0), ImmutableList.of());
-        if (nondeterministicFunctionChanged(whateverPlan, connectContext, sqlCacheContext)) {
-            return invalidateCache(key);
-        }
+            // check table and view and their columns authority
+            if (privilegeChanged(connectContext, env, sqlCacheContext)) {
+                return invalidateCache(key);
+            }
+            if (tablesOrDataChanged(env, sqlCacheContext)) {
+                return invalidateCache(key);
+            }
+            if (viewsChanged(env, sqlCacheContext)) {
+                return invalidateCache(key);
+            }
 
-        // table structure and data not changed, now check policy
-        if (rowPoliciesChanged(currentUserIdentity, env, sqlCacheContext)) {
-            return invalidateCache(key);
-        }
-        if (dataMaskPoliciesChanged(currentUserIdentity, env, sqlCacheContext)) {
-            return invalidateCache(key);
-        }
+            LogicalEmptyRelation whateverPlan = new LogicalEmptyRelation(new RelationId(0), ImmutableList.of());
+            if (nondeterministicFunctionChanged(whateverPlan, connectContext, sqlCacheContext)) {
+                return invalidateCache(key);
+            }
 
-        try {
+            // table structure and data not changed, now check policy
+            if (rowPoliciesChanged(currentUserIdentity, env, sqlCacheContext)) {
+                return invalidateCache(key);
+            }
+            if (dataMaskPoliciesChanged(currentUserIdentity, env, sqlCacheContext)) {
+                return invalidateCache(key);
+            }
             Optional<ResultSet> resultSetInFe = sqlCacheContext.getResultSetInFe();
 
             List<Variable> currentVariables = ImmutableList.of();

fe/fe-core/src/main/java/org/apache/doris/qe/cache/CacheAnalyzer.java

@@ -467,54 +467,58 @@ private CacheMode innerCheckCacheModeForNereids(long now) {
     }
 
     private List<CacheTable> buildCacheTableList() {
-        //Check the last version time of the table
-        MetricRepo.COUNTER_QUERY_TABLE.increase(1L);
-        long olapScanNodeSize = 0;
-        long hiveScanNodeSize = 0;
-        for (ScanNode scanNode : scanNodes) {
-            if (scanNode instanceof OlapScanNode) {
-                olapScanNodeSize++;
-            } else if (scanNode instanceof HiveScanNode) {
-                hiveScanNodeSize++;
+        try {
+            //Check the last version time of the table
+            MetricRepo.COUNTER_QUERY_TABLE.increase(1L);
+            long olapScanNodeSize = 0;
+            long hiveScanNodeSize = 0;
+            for (ScanNode scanNode : scanNodes) {
+                if (scanNode instanceof OlapScanNode) {
+                    olapScanNodeSize++;
+                } else if (scanNode instanceof HiveScanNode) {
+                    hiveScanNodeSize++;
+                }
             }
-        }
-        if (olapScanNodeSize > 0) {
-            MetricRepo.COUNTER_QUERY_OLAP_TABLE.increase(1L);
-        }
-        if (hiveScanNodeSize > 0) {
-            MetricRepo.COUNTER_QUERY_HIVE_TABLE.increase(1L);
-        }
-
-        if (!(olapScanNodeSize == scanNodes.size() || hiveScanNodeSize == scanNodes.size())) {
-            if (LOG.isDebugEnabled()) {
-                LOG.debug("only support olap/hive table with non-federated query, other types are not supported now, "
-                        + "queryId {}", DebugUtil.printId(queryId));
+            if (olapScanNodeSize > 0) {
+                MetricRepo.COUNTER_QUERY_OLAP_TABLE.increase(1L);
+            }
+            if (hiveScanNodeSize > 0) {
+                MetricRepo.COUNTER_QUERY_HIVE_TABLE.increase(1L);
             }
-            return Collections.emptyList();
-        }
 
-        List<CacheTable> tblTimeList = Lists.newArrayList();
-        for (int i = 0; i < scanNodes.size(); i++) {
-            ScanNode node = scanNodes.get(i);
-            if (enablePartitionCache()
-                    && (node instanceof OlapScanNode)
-                    && ((OlapScanNode) node).getSelectedPartitionNum() > 1
-                    && selectStmt != null
-                    && selectStmt.hasGroupByClause()) {
+            if (!(olapScanNodeSize == scanNodes.size() || hiveScanNodeSize == scanNodes.size())) {
                 if (LOG.isDebugEnabled()) {
-                    LOG.debug("more than one partition scanned when qeury has agg, "
-                                    + "partition cache cannot use, queryid {}",
-                            DebugUtil.printId(queryId));
+                    LOG.debug("only support olap/hive table with non-federated query, "
+                            + "other types are not supported now, queryId {}", DebugUtil.printId(queryId));
                 }
                 return Collections.emptyList();
             }
-            CacheTable cTable = node instanceof OlapScanNode
-                    ? buildCacheTableForOlapScanNode((OlapScanNode) node)
-                    : buildCacheTableForHiveScanNode((HiveScanNode) node);
-            tblTimeList.add(cTable);
+
+            List<CacheTable> tblTimeList = Lists.newArrayList();
+            for (int i = 0; i < scanNodes.size(); i++) {
+                ScanNode node = scanNodes.get(i);
+                if (enablePartitionCache()
+                        && (node instanceof OlapScanNode)
+                        && ((OlapScanNode) node).getSelectedPartitionNum() > 1
+                        && selectStmt != null
+                        && selectStmt.hasGroupByClause()) {
+                    if (LOG.isDebugEnabled()) {
+                        LOG.debug("more than one partition scanned when qeury has agg, "
+                                        + "partition cache cannot use, queryid {}",
+                                DebugUtil.printId(queryId));
+                    }
+                    return Collections.emptyList();
+                }
+                CacheTable cTable = node instanceof OlapScanNode
+                        ? buildCacheTableForOlapScanNode((OlapScanNode) node)
+                        : buildCacheTableForHiveScanNode((HiveScanNode) node);
+                tblTimeList.add(cTable);
+            }
+            Collections.sort(tblTimeList);
+            return tblTimeList;
+        } catch (Throwable t) {
+            return new ArrayList<>();
         }
-        Collections.sort(tblTimeList);
-        return tblTimeList;
     }
 
     public InternalService.PFetchCacheResult getCacheData() throws UserException {