为了更快的定位您的问题，请提供以下信息，谢谢
【详述】我是使用routingload将kafka数据加载到starrocks，在此基础上创建异步物化视图进行聚合统计。再在物化视图上创建普通视图提供数据查询。但在查询时会偶发java.lang.NullPointerException: null。
【背景】无
【业务影响】查询经常性报错
【是否存算分离】否
【StarRocks版本】2.5.22
【集群规模】3fe+8be（fe与be混部）
【联系方式】社区群7-小帅虎
【附件】
- fe.log
32106-2025-07-31 08:45:59,737 INFO (starrocks-taskrun-pool-180|6405) [QeProcessorImpl.unregisterQuery():93] deregister query id b9a8f94d-6da7-11f0-9fe6-b4055de04fc4
32107-2025-07-31 08:45:59,738 INFO (starrocks-taskrun-pool-180|6405) [InsertOverwriteJobRunner.handle():126] insert overwrite job:637772789 succeed. createPartitionElapse:33 ms, insertElapse:286 ms
32108-2025-07-31 08:45:59,738 INFO (starrocks-taskrun-pool-180|6405) [PartitionBasedMvRefreshProcessor.refreshMaterializedView():1032] finished to refresh materialized view mv_realtime_ads_bi_rtac_tra_pay_sto_hour_d, query_id:b9a8f94d-6da7-11f0-9fe6-b4055de04fc4
32109-2025-07-31 08:45:59,738 INFO (starrocks-taskrun-pool-180|6405) [MetadataMgr.removeQueryMetadata():113] Succeed to deregister query level connector metadata on query id: b9a8f94d-6da7-11f0-9fe6-b4055de04fc4
32110-2025-07-31 08:45:59,739 INFO (starrocks-taskrun-pool-180|6405) [TaskRun.executeTaskRun():189] finished to execute task run, task_id:624086225, query_id:b9a8f94d-6da7-11f0-9fe6-b4055de04fc4, query_state:OK
32111-2025-07-31 08:45:59,741 INFO (starrocks-mysql-nio-pool-983|6311) [MetadataMgr.removeQueryMetadata():113] Succeed to deregister query level connector metadata on query id: b9fb3806-6da7-11f0-9fe6-b4055de04fc4
32112-2025-07-31 08:45:59,741 WARN (starrocks-mysql-nio-pool-983|6311) [StmtExecutor.execute():615] execute Exception, sql SELECT ‘B2C’ AS sourceId, MAX(m.update_time) AS lastUpdateTime, -1 AS platformId, NUll as platform_name, ROUND(SUM(pay_amt_no_tax)/100,4) AS orderAmt, SUM(pay_order_cnt) AS orderNum, SUM(pay_qty) AS orderItemQty, ROUND(SUM(fresh_pay_amt_no_tax)/100,4) AS freshAmt, ROUND(SUM(pay_amt)/100,4) AS afterDiscountAmt, ROUND(SUM(discount_amt)/100,4) AS discountAmt, ROUND(SUM(CASE WHEN source_id IN (12,13) THEN cus_pay_amt ELSE pay_amt END)/100,4) AS cusOrderAmt FROM rpt.vi_bi_realtime_rtac_dz_pay_sto_source_hour_d m WHERE dt = CURDATE() and m.store_type in (‘1’) and m.store_id in (‘1250’) AND source_id IN (SELECT source_id FROM dwd.dim_order_source_cd WHERE mark = 1) UNION ALL SELECT ‘S1’ AS sourceId, MAX(m.update_time) AS lastUpdateTime, -1 AS platformId, NUll as platform_name, ROUND(SUM(pay_amt_no_tax)/100,4) AS orderAmt, SUM(pay_order_cnt) AS orderNum, SUM(pay_qty) AS orderItemQty, ROUND(SUM(fresh_pay_amt_no_tax)/100,4) AS freshAmt, ROUND(SUM(pay_amt)/100,4) AS afterDiscountAmt, ROUND(SUM(discount_amt)/100,4) AS discountAmt, ROUND(SUM(CASE WHEN source_id IN (12,13) THEN cus_pay_amt ELSE pay_amt END)/100,4) AS cusOrderAmt FROM rpt.vi_bi_realtime_rtac_dz_pay_sto_source_hour_d m WHERE dt = CURDATE() and m.store_type in (‘1’) and m.store_id in (‘1250’) AND source_id IN (SELECT source_id FROM dwd.dim_order_source_cd WHERE is_s1 = 1) UNION ALL SELECT ‘S2’ AS sourceId, MAX(m.update_time) AS lastUpdateTime, -1 AS platformId, NUll as platform_name, ROUND(SUM(pay_amt_no_tax)/100,4) AS orderAmt, SUM(pay_order_cnt) AS orderNum, SUM(pay_qty) AS orderItemQty, ROUND(SUM(fresh_pay_amt_no_tax)/100,4) AS freshAmt, ROUND(SUM(pay_amt)/100,4) AS afterDiscountAmt, ROUND(SUM(discount_amt)/100,4) AS discountAmt, ROUND(SUM(CASE WHEN source_id IN (12,13) THEN cus_pay_amt ELSE pay_amt END)/100,4) AS cusOrderAmt FROM rpt.vi_bi_realtime_rtac_dz_pay_sto_source_hour_d m WHERE dt = CURDATE() and m.store_type in (‘1’) and m.store_id in (‘1250’) AND source_id IN (SELECT source_id FROM dwd.dim_order_source_cd WHERE is_s2 = 1) UNION ALL SELECT a.source_id AS sourceId, lastUpdateTime AS lastUpdateTime, NUll AS platformId, NUll as platform_name, orderAmt AS orderAmt, orderNum AS orderNum, orderItemQty AS orderItemQty, freshAmt AS freshAmt, afterDiscountAmt AS afterDiscountAmt, discountAmt AS discountAmt, cusOrderAmt AS cusOrderAmt FROM ( SELECT source_id FROM dwd.dim_order_source_cd WHERE source_id in (‘33’,‘12’,‘2’,‘B2C’,‘25’,‘27’,‘50’,‘S1’,‘10’,‘S2’) ) a LEFT JOIN ( SELECT source_id, MAX(m.update_time) AS lastUpdateTime, ROUND(SUM(pay_amt_no_tax)/100,4) AS orderAmt, SUM(pay_order_cnt) AS orderNum, SUM(pay_qty) AS orderItemQty, ROUND(SUM(fresh_pay_amt_no_tax)/100,4) AS freshAmt, ROUND(SUM(pay_amt)/100,4) AS afterDiscountAmt, ROUND(SUM(discount_amt)/100,4) AS discountAmt, ROUND(SUM(CASE WHEN source_id IN (12,13) THEN cus_pay_amt ELSE pay_amt END)/100,4) AS cusOrderAmt FROM rpt.vi_bi_realtime_rtac_dz_pay_sto_source_hour_d m WHERE dt = CURDATE() and m.store_type in (‘1’) and m.store_id in (‘1250’) AND source_id in (‘33’,‘12’,‘2’,‘B2C’,‘25’,‘27’,‘50’,‘S1’,‘10’,‘S2’) GROUP BY source_id ) b ON a.source_id = b.source_id
32113-java.lang.NullPointerException: null
32114-2025-07-31 08:45:59,741 INFO (starrocks-mysql-nio-pool-983|6311) [MetadataMgr.removeQueryMetadata():113] Succeed to deregister query level connector metadata on query id: b9fb3806-6da7-11f0-9fe6-b4055de04fc4
32115:2025-07-31 08:45:59,741 INFO (starrocks-mysql-nio-pool-1026|6483) [MetadataMgr.removeQueryMetadata():113] Succeed to deregister query level connector metadata on query id: b9ff2fa7-6da7-11f0-9fe6-b4055de04fc4
32116-2025-07-31 08:45:59,741 WARN (starrocks-mysql-nio-pool-1026|6483) [StmtExecutor.execute():615] execute Exception, sql SELECT hour_id, ROUND(orderAmt/100,4) AS orderAmt, orderNum, ROUND(hbOrderAmt/100,4) AS hbOrderAmt, hbOrderNum as hbOrderNum, ROUND(tbOrderAmt/100,4) AS tbOrderAmt, tbOrderNum, date_format(b.lastUpdateTime, ‘%Y-%m-%d %H:%I:%s’) AS lastUpdateTime FROM dwd.dim_hour a LEFT JOIN ( SELECT hour_id AS hourId, SUM(pay_amt_no_tax) AS orderAmt, SUM(pay_order_cnt) AS orderNum, MAX(update_time) AS lastUpdateTime FROM rpt.vi_bi_realtime_rtac_dz_pay_sto_source_hour_d WHERE dt = CURDATE() AND source_id IN (SELECT source_id FROM dwd.dim_order_source_cd WHERE mark = 1) AND store_id in (‘2070’,‘2034’,‘2078’,‘2033’,‘2077’,‘2032’,‘2076’,‘2075’,‘2030’,‘2074’,‘2073’,‘2072’,‘2071’,‘2701’,‘2029’,‘2028’,‘2027’,‘2026’,‘2025’,‘2300’,‘2024’,‘2001’,‘2045’,‘2044’,‘2043’,‘2041’,‘2039’,‘2037’,‘2036’,‘2079’,‘2035’,‘2056’,‘2012’,‘2011’,‘2055’,‘2010’,‘2054’,‘2053’,‘2052’,‘2051’,‘2050’,‘2009’,‘2008’,‘2007’,‘2006’,‘2401’,‘2049’,‘2400’,‘2003’,‘2047’,‘2023’,‘2022’,‘2020’,‘2064’,‘2063’,‘2062’,‘2060’,‘2018’,‘2017’,‘2016’,‘2015’,‘2014’,‘2013’,‘2057’) GROUP BY hour_id ) b on a.hour_id = b.hourId LEFT JOIN ( SELECT hour_id AS hbHourId, SUM(pay_amt_no_tax) AS hbOrderAmt, SUM(pay_order_cnt) AS hbOrderNum, MAX(update_time) AS hbLastUpdateTime FROM rpt.vi_bi_realtime_rtac_dz_pay_sto_source_hour_d WHERE dt = date_sub(CURDATE(), INTERVAL 1 DAY) AND source_id IN (SELECT source_id FROM dwd.dim_order_source_cd WHERE mark = 1) AND store_id in (‘2070’,‘2034’,‘2078’,‘2033’,‘2077’,‘2032’,‘2076’,‘2075’,‘2030’,‘2074’,‘2073’,‘2072’,‘2071’,‘2701’,‘2029’,‘2028’,‘2027’,‘2026’,‘2025’,‘2300’,‘2024’,‘2001’,‘2045’,‘2044’,‘2043’,‘2041’,‘2039’,‘2037’,‘2036’,‘2079’,‘2035’,‘2056’,‘2012’,‘2011’,‘2055’,‘2010’,‘2054’,‘2053’,‘2052’,‘2051’,‘2050’,‘2009’,‘2008’,‘2007’,‘2006’,‘2401’,‘2049’,‘2400’,‘2003’,‘2047’,‘2023’,‘2022’,‘2020’,‘2064’,‘2063’,‘2062’,‘2060’,‘2018’,‘2017’,‘2016’,‘2015’,‘2014’,‘2013’,‘2057’) GROUP BY hour_id ) hb ON a.hour_id = hb.hbHourId LEFT JOIN ( SELECT hour_id AS tbHourId, SUM(pay_amt_no_tax) AS tbOrderAmt, SUM(pay_order_cnt) AS tbOrderNum, MAX(update_time) AS tbLastUpdateTime FROM rpt.vi_bi_realtime_rtac_dz_pay_sto_source_hour_d WHERE dt = date_sub(CURDATE(), INTERVAL 1 WEEK) AND source_id IN (SELECT source_id FROM dwd.dim_order_source_cd WHERE mark = 1) AND store_id in (‘2070’,‘2034’,‘2078’,‘2033’,‘2077’,‘2032’,‘2076’,‘2075’,‘2030’,‘2074’,‘2073’,‘2072’,‘2071’,‘2701’,‘2029’,‘2028’,‘2027’,‘2026’,‘2025’,‘2300’,‘2024’,‘2001’,‘2045’,‘2044’,‘2043’,‘2041’,‘2039’,‘2037’,‘2036’,‘2079’,‘2035’,‘2056’,‘2012’,‘2011’,‘2055’,‘2010’,‘2054’,‘2053’,‘2052’,‘2051’,‘2050’,‘2009’,‘2008’,‘2007’,‘2006’,‘2401’,‘2049’,‘2400’,‘2003’,‘2047’,‘2023’,‘2022’,‘2020’,‘2064’,‘2063’,‘2062’,‘2060’,‘2018’,‘2017’,‘2016’,‘2015’,‘2014’,‘2013’,‘2057’) GROUP BY hour_id ) tb ON a.hour_id = tb.tbHourId ORDER BY hour_id
32117-java.lang.NullPointerException: null
32118:2025-07-31 08:45:59,741 INFO (starrocks-mysql-nio-pool-1026|6483) [MetadataMgr.removeQueryMetadata():113] Succeed to deregister query level connector metadata on query id: b9ff2fa7-6da7-11f0-9fe6-b4055de04fc4
32119-2025-07-31 08:45:59,741 INFO (starrocks-mysql-nio-pool-1027|6485) [MetadataMgr.removeQueryMetadata():113] Succeed to deregister query level connector metadata on query id: ba008f38-6da7-11f0-9fe6-b4055de04fc4
32120-2025-07-31 08:45:59,741 INFO (starrocks-mysql-nio-pool-1027|6485) [QeProcessorImpl.registerQuery():83] register query id = ba008f38-6da7-11f0-9fe6-b4055de04fc4, job: -1
32121-2025-07-31 08:45:59,775 INFO (starrocks-mysql-nio I/O-4|98) [AcceptListener.handleEvent():66] Connection established. remote=/10.201.197.207:58726, connectionId=46910
32122-2025-07-31 08:45:59,775 INFO (starrocks-mysql-nio-pool-1026|6483) [AcceptListener.lambda$handleEvent$1():73] Connection scheduled to worker thread 6483. remote=/10.201.197.207:58726, connectionId=46910
32123-2025-07-31 08:45:59,775 INFO (starrocks-mysql-nio-pool-1026|6483) [ConnectScheduler.unregisterConnection():153] Connection closed. remote=10.201.197.207:58726, connectionId=46910
32124-2025-07-31 08:45:59,843 INFO (thrift-server-pool-726|2243) [FrontendServiceImpl.loadTxnCommit():989] receive txn commit request. db: dwd, tbl: fct_realtime_rtac_tra_subs_item_di, txn_id: 140792252, backend: 10.201.211.30
32125-2025-07-31 08:45:59,845 INFO (thrift-server-pool-726|2243) [DatabaseTransactionMgr.commitTransaction():485] transaction:[TransactionState. txn_id: 140792252, label: 70aa59db-3a3e-439d-be63-52a0c8026415, db id: 10053, table id list: 117358449, callback id: 598423662, coordinator: FE: 10.201.211.25, transaction status: COMMITTED, error replicas num: 0, replica ids: , prepare time: 1753922759298, commit time: 1753922759844, finish time: -1, write cost: 546ms, reason: attachment: RLTaskTxnCommitAttachment [filteredRows=0, loadedRows=29, unselectedRows=0, receivedBytes=77263, taskExecutionTimeMs=535, taskId=TUniqueId(hi:8118400076398609309, lo:-4727844333305043947), jobId=598423662, progress=KafkaProgress [partitionIdToOffset=3_1255662239|8_1251643113]] tabletCommitInfos size: 24] successfully committed