【是否存算分离】否
【StarRocks版本】2.5.20
【集群规模】3fe+8be(fe与be混部)
SELECT ‘-’ AS T_A1_2_, ‘-’ AS T_A2_3_, ‘-’ AS T_A3_4_, ‘-’ AS T_A4_5_, ‘-’ AS T_A5_6_, SUM(A54_T_1_.amt_mtd
) AS T_ADC_7_, CASE WHEN sum( A54_T_1_.comp_amt_lmtd
* A54_T_1_.is_comp
) = 0 THEN null
ELSE (sum( A54_T_1_.comp_amt_mtd
* A54_T_1_.is_comp
)-sum( A54_T_1_.comp_amt_lmtd
* A54_T_1_.is_comp
))
/ abs(sum( A54_T_1_.comp_amt_lmtd
* A54_T_1_.is_comp
))
END AS T_A96_8_, SUM(A54_T_1_.client_cnt_mtd
) AS T_A6B_9_, case when sum( A54_T_1_.client_cnt_lmtd
* A54_T_1_.is_comp
)=0 then null
else sum( A54_T_1_.client_cnt_mtd
* A54_T_1_.is_comp
)/sum( A54_T_1_.client_cnt_lmtd
* A54_T_1_.is_comp
)-1
end AS T_A87_10_, case when sum( A54_T_1_.client_cnt_store_mtd
)=0 then 0
else
sum( A54_T_1_.client_cnt_mtd
) /sum( A54_T_1_.client_cnt_store_mtd
)
end AS T_A20_11_, CASE WHEN sum( A54_T_1_.amt_mtd
)=0 THEN 0
ELSE (sum( A54_T_1_.gp_amt_mtd
)/sum( A54_T_1_.amt_mtd
))
END AS T_AE4_12_, case when sum( A54_T_1_.client_cnt_mtd
)=0 then 0
else
sum( A54_T_1_.amt_h108_mtd
) /sum( A54_T_1_.client_cnt_mtd
)
end AS T_AC1_13_, SUM(A54_T_1_.amt_ytd_f
) AS T_AFE_14_, CASE WHEN sum( A54_T_1_.comp_amt_lytd_f
* A54_T_1_.is_comp
) = 0 THEN null
ELSE (sum( A54_T_1_.comp_amt_ytd_f
* A54_T_1_.is_comp
)-sum( A54_T_1_.comp_amt_lytd_f
* A54_T_1_.is_comp
))
/ abs(sum( A54_T_1_.comp_amt_lytd_f
* A54_T_1_.is_comp
))
END AS T_AD1_15_, SUM(A54_T_1_.client_cnt_ytd_f
) AS T_A52_16_, case when sum( A54_T_1_.comp_client_cnt_lytd_f
* A54_T_1_.is_comp
)=0 then null
else sum( A54_T_1_.comp_client_cnt_ytd_f
* A54_T_1_.is_comp
)/sum( A54_T_1_.comp_client_cnt_lytd_f
* A54_T_1_.is_comp
)-1
end AS T_A70_17_, case when sum( A54_T_1_.client_cnt_store_ytd_f
)=0 then 0
else
sum( A54_T_1_.client_cnt_ytd_f
) /sum( A54_T_1_.client_cnt_store_ytd_f
)
end AS T_A3E_18_, CASE WHEN sum( A54_T_1_.amt_ytd_f
)=0 THEN 0
ELSE (sum( A54_T_1_.gp_amt_ytd_f
)/sum( A54_T_1_.amt_ytd_f
))
END AS T_A02_19_, case when sum( A54_T_1_.client_cnt_ytd_f
)=0 then 0
else
sum( A54_T_1_.amt_h108_ytd_f
) /sum( A54_T_1_.client_cnt_ytd_f
)
end AS T_ACE_20_ FROM (select *
,concat(level_id,’ - ‘,level_name) AS level_id_name
from rpt.vi_sr_dws_rtac_store_source_cate_level_comp_h108_di_ho
where ‘BI’ = ‘BI’
) AS A54_T_1_ WHERE A54_T_1_.source_id
= ‘0’ AND A54_T_1_.id_day
>= STR_TO_DATE(‘2025-01-01 00:00:00’,’%Y-%m-%d %H:%i:%s’) AND A54_T_1_.id_day
<= STR_TO_DATE(‘2025-03-31 23:59:59’,’%Y-%m-%d %H:%i:%s’) AND A54_T_1_.section_id
IN (‘10’, ‘11’, ‘12’, ‘13’, ‘14’, ‘16’) AND CAST(A54_T_1_.level_type
AS STRING) = ‘4’ AND A54_T_1_.is_monthend
= 1 AND A54_T_1_.sub_region_id
IN (‘2_1’) AND A54_T_1_.business_store_id
IN (‘2034’) AND A54_T_1_.region_id
IN (‘2’) LIMIT 0, 1000
以上SQL查询时,会有以下出错日志,但是能执行成功,查询出数据。
java.lang.IllegalStateException: ConstantRef-cmp-ConstantRef not supported here, should be eliminated earlier: 0 = 0
at com.google.common.base.Preconditions.checkState(Preconditions.java:512) ~[spark-dpp-1.0.0.jar:?]
at com.starrocks.sql.optimizer.statistics.PredicateStatisticsCalculator$PredicateStatisticsCalculatingVisitor.visitBinaryPredicate(PredicateStatisticsCalculator.java:205) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.statistics.PredicateStatisticsCalculator$PredicateStatisticsCalculatingVisitor.visitBinaryPredicate(PredicateStatisticsCalculator.java:51) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.operator.scalar.BinaryPredicateOperator.accept(BinaryPredicateOperator.java:61) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.statistics.PredicateStatisticsCalculator$PredicateStatisticsCalculatingVisitor.visitCompoundPredicate(PredicateStatisticsCalculator.java:272) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.statistics.PredicateStatisticsCalculator$PredicateStatisticsCalculatingVisitor.visitCompoundPredicate(PredicateStatisticsCalculator.java:51) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.operator.scalar.CompoundPredicateOperator.accept(CompoundPredicateOperator.java:36) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.statistics.PredicateStatisticsCalculator.statisticsCalculate(PredicateStatisticsCalculator.java:34) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.statistics.StatisticsCalculator.estimateStatistics(StatisticsCalculator.java:1205) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.statistics.StatisticsCalculator.visitOperator(StatisticsCalculator.java:174) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.statistics.StatisticsCalculator.computeFilterNode(StatisticsCalculator.java:1169) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.statistics.StatisticsCalculator.visitLogicalFilter(StatisticsCalculator.java:1153) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.statistics.StatisticsCalculator.visitLogicalFilter(StatisticsCalculator.java:138) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.operator.logical.LogicalFilterOperator.accept(LogicalFilterOperator.java:43) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.statistics.StatisticsCalculator.estimatorStats(StatisticsCalculator.java:154) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.task.DeriveStatsTask.execute(DeriveStatsTask.java:44) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.task.SeriallyTaskScheduler.executeTasks(SeriallyTaskScheduler.java:68) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.Optimizer.memoOptimize(Optimizer.java:447) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.Optimizer.optimizeByCost(Optimizer.java:154) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.Optimizer.optimize(Optimizer.java:96) ~[starrocks-fe.jar:?]
at com.starrocks.sql.StatementPlanner.createQueryPlanWithReTry(StatementPlanner.java:177) ~[starrocks-fe.jar:?]
at com.starrocks.sql.StatementPlanner.plan(StatementPlanner.java:82) ~[starrocks-fe.jar:?]
at com.starrocks.sql.StatementPlanner.plan(StatementPlanner.java:49) ~[starrocks-fe.jar:?]
at com.starrocks.qe.StmtExecutor.execute(StmtExecutor.java:457) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.handleQuery(ConnectProcessor.java:337) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.dispatch(ConnectProcessor.java:446) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.processOnce(ConnectProcessor.java:723) ~[starrocks-fe.jar:?]
at com.starrocks.mysql.nio.ReadListener.lambda$handleEvent$0(ReadListener.java:55) ~[starrocks-fe.jar:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
at java.lang.Thread.run(Thread.java:834) ~[?:?]