starrocks
starrocks copied to clipboard
unknow error when ctas ue cte
Steps to reproduce the behavior (Required)
CREATE TABLE `duplicate_tbl` (
`dk1` date NULL COMMENT "",
`dk2` datetime NULL COMMENT "",
`dk3` char(20) NULL COMMENT "",
`dk4` varchar(20) NULL COMMENT "",
`dk5` boolean NULL COMMENT "",
`dk6` tinyint(4) NULL COMMENT "",
`dk7` smallint(6) NULL COMMENT "",
`dk8` int(11) NULL COMMENT "",
`dk9` bigint(20) NULL COMMENT "",
`dk10` largeint(40) NULL COMMENT "",
`dk11` float NULL COMMENT "",
`dk12` double NULL COMMENT "",
`dk13` decimal128(27, 9) NULL COMMENT ""
) ENGINE=OLAP
DUPLICATE KEY(`dk1`, `dk2`, `dk3`, `dk4`, `dk5`)
COMMENT "OLAP"
DISTRIBUTED BY HASH(`dk1`, `dk2`, `dk3`) BUCKETS 3
PROPERTIES (
"replication_num" = "1",
"in_memory" = "false",
"storage_format" = "DEFAULT",
"enable_persistent_index" = "false"
);
CREATE TABLE `primary_par_tbl` (
`ppk1` date NOT NULL COMMENT "",
`ppk2` datetime NOT NULL COMMENT "",
`ppk3` varchar(20) NOT NULL COMMENT "",
`ppk4` varchar(20) NOT NULL COMMENT "",
`ppk5` boolean NOT NULL COMMENT "",
`ppk6` tinyint(4) NULL COMMENT "",
`ppk7` smallint(6) NULL COMMENT "",
`ppk8` int(11) NULL COMMENT "",
`ppk9` bigint(20) NULL COMMENT "",
`ppk10` largeint(40) NULL COMMENT "",
`ppk11` float NULL COMMENT "",
`ppk12` double NULL COMMENT "",
`ppk13` decimal128(27, 9) NULL COMMENT ""
) ENGINE=OLAP
PRIMARY KEY(`ppk1`, `ppk2`, `ppk3`, `ppk4`, `ppk5`)
COMMENT "OLAP"
PARTITION BY RANGE(`ppk1`)
(PARTITION p202006 VALUES [('0000-01-01'), ('2020-07-01')),
PARTITION p202007 VALUES [('2020-07-01'), ('2020-08-01')),
PARTITION p202008 VALUES [('2020-08-01'), ('2020-09-01')))
DISTRIBUTED BY HASH(`ppk1`, `ppk2`, `ppk3`, `ppk4`, `ppk5`) BUCKETS 3
PROPERTIES (
"replication_num" = "1",
"in_memory" = "false",
"storage_format" = "DEFAULT",
"enable_persistent_index" = "false"
);
create table t1 as with tbl as (select dk1,dk2,dk10+dk11+dk12+dk13 as dk3 from duplicate_tbl where dk1 in(select distinct ppk1 from primary_par_tbl partition(p202008) order by 1 desc limit 10) limit 100) select * from tbl order by 1,2 desc,3;
Expected behavior (Required)
query ok
Real behavior (Required)
2022-07-23 15:43:58,217 WARN (starrocks-mysql-nio-pool-45|616) [StmtExecutor.handleCreateTableAsSelectStmt():538] handle create table as select stmt fail
java.lang.IllegalStateException: null
at com.google.common.base.Preconditions.checkState(Preconditions.java:494) ~[spark-dpp-1.0.0.jar:?]
at com.starrocks.sql.plan.ScalarOperatorToExpr$Formatter.visitVariableReference(ScalarOperatorToExpr.java:108) ~[starrocks-fe.jar:?]
at com.starrocks.sql.plan.ScalarOperatorToExpr$Formatter.visitVariableReference(ScalarOperatorToExpr.java:93) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.operator.scalar.ColumnRefOperator.accept(ColumnRefOperator.java:99) ~[starrocks-fe.jar:?]
at com.starrocks.sql.plan.ScalarOperatorToExpr.buildExecExpression(ScalarOperatorToExpr.java:69) ~[starrocks-fe.jar:?]
at com.starrocks.sql.plan.PlanFragmentBuilder$PhysicalPlanTranslator.buildPartialTopNFragment(PlanFragmentBuilder.java:1499) ~[starrocks-fe.jar:?]
at com.starrocks.sql.plan.PlanFragmentBuilder$PhysicalPlanTranslator.visitPhysicalTopN(PlanFragmentBuilder.java:1415) ~[starrocks-fe.jar:?]
at com.starrocks.sql.plan.PlanFragmentBuilder$PhysicalPlanTranslator.visitPhysicalTopN(PlanFragmentBuilder.java:258) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.operator.physical.PhysicalTopNOperator.accept(PhysicalTopNOperator.java:110) ~[starrocks-fe.jar:?]
at com.starrocks.sql.plan.PlanFragmentBuilder$PhysicalPlanTranslator.visit(PlanFragmentBuilder.java:267) ~[starrocks-fe.jar:?]
at com.starrocks.sql.plan.PlanFragmentBuilder.createPhysicalPlanWithoutOutputFragment(PlanFragmentBuilder.java:166) ~[starrocks-fe.jar:?]
at com.starrocks.sql.InsertPlanner.plan(InsertPlanner.java:116) ~[starrocks-fe.jar:?]
at com.starrocks.sql.StatementPlanner.plan(StatementPlanner.java:101) ~[starrocks-fe.jar:?]
at com.starrocks.qe.StmtExecutor.handleCreateTableAsSelectStmt(StmtExecutor.java:529) ~[starrocks-fe.jar:?]
at com.starrocks.qe.StmtExecutor.execute(StmtExecutor.java:432) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.handleQuery(ConnectProcessor.java:283) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.dispatch(ConnectProcessor.java:401) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.processOnce(ConnectProcessor.java:637) ~[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_262]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_262]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_262]
2022-07-23 15:43:58,219 WARN (starrocks-mysql-nio-pool-45|616) [StmtExecutor.execute():482] execute Exception, sql create table t1 as with tbl as (select dk1,dk2,dk10+dk11+dk12+dk13 as dk3 from duplicate_tbl where dk1 in(select distinct ppk1 from primary_par_tbl partition(p202008) order by 1 desc limit 10) limit 100) select * from tbl order by 1,2 desc,3
java.lang.IllegalStateException: null
at com.google.common.base.Preconditions.checkState(Preconditions.java:494) ~[spark-dpp-1.0.0.jar:?]
at com.starrocks.sql.plan.ScalarOperatorToExpr$Formatter.visitVariableReference(ScalarOperatorToExpr.java:108) ~[starrocks-fe.jar:?]
at com.starrocks.sql.plan.ScalarOperatorToExpr$Formatter.visitVariableReference(ScalarOperatorToExpr.java:93) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.operator.scalar.ColumnRefOperator.accept(ColumnRefOperator.java:99) ~[starrocks-fe.jar:?]
at com.starrocks.sql.plan.ScalarOperatorToExpr.buildExecExpression(ScalarOperatorToExpr.java:69) ~[starrocks-fe.jar:?]
at com.starrocks.sql.plan.PlanFragmentBuilder$PhysicalPlanTranslator.buildPartialTopNFragment(PlanFragmentBuilder.java:1499) ~[starrocks-fe.jar:?]
at com.starrocks.sql.plan.PlanFragmentBuilder$PhysicalPlanTranslator.visitPhysicalTopN(PlanFragmentBuilder.java:1415) ~[starrocks-fe.jar:?]
at com.starrocks.sql.plan.PlanFragmentBuilder$PhysicalPlanTranslator.visitPhysicalTopN(PlanFragmentBuilder.java:258) ~[starrocks-fe.jar:?]
at com.starrocks.sql.optimizer.operator.physical.PhysicalTopNOperator.accept(PhysicalTopNOperator.java:110) ~[starrocks-fe.jar:?]
at com.starrocks.sql.plan.PlanFragmentBuilder$PhysicalPlanTranslator.visit(PlanFragmentBuilder.java:267) ~[starrocks-fe.jar:?]
at com.starrocks.sql.plan.PlanFragmentBuilder.createPhysicalPlanWithoutOutputFragment(PlanFragmentBuilder.java:166) ~[starrocks-fe.jar:?]
at com.starrocks.sql.InsertPlanner.plan(InsertPlanner.java:116) ~[starrocks-fe.jar:?]
at com.starrocks.sql.StatementPlanner.plan(StatementPlanner.java:101) ~[starrocks-fe.jar:?]
at com.starrocks.qe.StmtExecutor.handleCreateTableAsSelectStmt(StmtExecutor.java:529) ~[starrocks-fe.jar:?]
at com.starrocks.qe.StmtExecutor.execute(StmtExecutor.java:432) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.handleQuery(ConnectProcessor.java:283) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.dispatch(ConnectProcessor.java:401) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.processOnce(ConnectProcessor.java:637) ~[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_262]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_262]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_262]
StarRocks version (Required)
- You can get the StarRocks version by executing SQL
select current_version()
mysql> select current_version();
+----------------------------+
| current_version() |
+----------------------------+
| BRANCH-2.3-RELEASE 345770c |
+----------------------------+