升级到2.5.4后concat报错

💬 StarRocks 用户问答 功能使用相关
#1

【详述】ERROR 1064 (HY000): Reach limit of connections
【背景】测试环境从2.3.8升级到2.5.4，concat函数报错，同样的SQL在原来2.3.8环境跑正常，在升级到2.5.4.报错，SQL语句，如下：
select
module,
EQPID,
mfgmonth ,
case
when mfgmonth = date_format(now(), ‘%Y-M%m’) then round(sum(total_time)/(dayofmonth(now())* 24 * 3600), 2)
else concat((REPLACE(mfgmonth, ‘M’, ‘’)), ‘01’)
end mth_time
from
(
select
c.module,
EQPID,
mfgmonth ,
total_time
from
(
select
testdate as mfgdate,
l.mfgmonth,
l.mfg_week as mfgweek,
EQPID,
total_time
from
(
select
EQPID,
REPLACE(testdate,
‘-’,
‘’)testdate ,
sum(total_time) total_time
from
(
select
toolid as EQPID,
testdate,
sum(time_difference) total_time
from
dx_ie.t_dwd_lab_site_user_summary
where
1 = 1
group by
toolid,
testdate
UNION all
SELECT
EQPID,
TEST_TIME,
sum(END_TIME-START_TIME) total_time
from
dx_ie.t_dwd_lab_eqp_upt
where
1 = 1
group by
EQPID,
TEST_TIME ) d
group by
EQPID,
testdate
order by
EQPID,
testdate ) e
left join dx_ie.rpt_brt_calendar_lst l on
e.testdate = l.mfgdate
where
1 = 1
and mfgdate >= date_format(date_sub(NOW(), interval 6 MONTH), ‘%Y%m%d’) ) f
left join dx_ie.t_tgt_lab_eqp_module_config c on
f.eqpid = c.eqid
where
1 = 1 ) r
group by
module,
EQPID,
mfgmonth
ORDER BY
mfgmonth desc
【StarRocks版本】2.5.4
【集群规模】3fe（3 follower）+5be
【联系方式】15623937986
【附件】
FE报错日志，如下：
group by
module,
EQPID,
mfgmonth
ORDER BY
mfgmonth desc
java.lang.IllegalStateException: null
at com.google.common.base.Preconditions.checkState(Preconditions.java:494) ~[spark-dpp-1.0.0.jar:?]
at com.starrocks.sql.optimizer.rule.tree.DictMappingRewriter$Rewriter.rewriteForScalarOperator(DictMappingRewriter.java:96) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.rule.tree.DictMappingRewriter$Rewriter.visitCall(DictMappingRewriter.java:149) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.rule.tree.DictMappingRewriter$Rewriter.visitCall(DictMappingRewriter.java:74) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.operator.scalar.CallOperator.accept(CallOperator.java:186) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.rule.tree.DictMappingRewriter$Rewriter.addDictExprToBlockDictOpt(DictMappingRewriter.java:118) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.rule.tree.DictMappingRewriter$Rewriter.visit(DictMappingRewriter.java:139) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.rule.tree.DictMappingRewriter$Rewriter.rewriteForScalarOperator(DictMappingRewriter.java:106) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.rule.tree.DictMappingRewriter$Rewriter.visitCall(DictMappingRewriter.java:149) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.rule.tree.DictMappingRewriter$Rewriter.visitCall(DictMappingRewriter.java:74) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.operator.scalar.CallOperator.accept(CallOperator.java:186) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.rule.tree.DictMappingRewriter.rewrite(DictMappingRewriter.java:42) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.rule.tree.AddDecodeNodeForDictStringRule$DecodeVisitor.rewriteOneScalarOperatorForProjection(AddDecodeNodeForDictStringRule.java:544) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.rule.tree.AddDecodeNodeForDictStringRule$DecodeVisitor.rewriteProjectOperator(AddDecodeNodeForDictStringRule.java:473) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.rule.tree.AddDecodeNodeForDictStringRule$DecodeVisitor.visitProjectionAfter(AddDecodeNodeForDictStringRule.java:247) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.rule.tree.AddDecodeNodeForDictStringRule$DecodeVisitor.visitPhysicalHashAggregate(AddDecodeNodeForDictStringRule.java:806) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.rule.tree.AddDecodeNodeForDictStringRule$DecodeVisitor.visitPhysicalHashAggregate(AddDecodeNodeForDictStringRule.java:171) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.operator.physical.PhysicalHashAggregateOperator.accept(PhysicalHashAggregateOperator.java:173) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.rule.tree.AddDecodeNodeForDictStringRule$DecodeVisitor.visitPhysicalTopN(AddDecodeNodeForDictStringRule.java:313) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.rule.tree.AddDecodeNodeForDictStringRule$DecodeVisitor.visitPhysicalTopN(AddDecodeNodeForDictStringRule.java:171) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.operator.physical.PhysicalTopNOperator.accept(PhysicalTopNOperator.java:113) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.rule.tree.AddDecodeNodeForDictStringRule$DecodeVisitor.visitPhysicalTopN(AddDecodeNodeForDictStringRule.java:313) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.rule.tree.AddDecodeNodeForDictStringRule$DecodeVisitor.visitPhysicalTopN(AddDecodeNodeForDictStringRule.java:171) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.operator.physical.PhysicalTopNOperator.accept(PhysicalTopNOperator.java:113) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.rule.tree.AddDecodeNodeForDictStringRule.rewrite(AddDecodeNodeForDictStringRule.java:913) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.Optimizer.physicalRuleRewrite(Optimizer.java:463) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.Optimizer.optimizeByCost(Optimizer.java:171) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.Optimizer.optimize(Optimizer.java:93) ~[starrocks-fe.jar:?]
at com.starrocks.sql.StatementPlanner.createQueryPlan(StatementPlanner.java:95) ~[starrocks-fe.jar:?]
at com.starrocks.sql.StatementPlanner.plan(StatementPlanner.java:66) ~[starrocks-fe.jar:?]
at com.starrocks.sql.StatementPlanner.plan(StatementPlanner.java:37) ~[starrocks-fe.jar:?]
at com.starrocks.qe.StmtExecutor.execute(StmtExecutor.java:379) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.handleQuery(ConnectProcessor.java:323) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.dispatch(ConnectProcessor.java:440) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.processOnce(ConnectProcessor.java:698) ~[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:1149) [?:1.8.0_181]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_181]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_181]

#2

这个报错是因为当前用户的连接数超限制了，默认限制100。可通过这个调整 SET PROPERTY FOR ‘jack’ ‘max_user_connections’ = ‘1000’;

京ICP备2022026421号-1