panhua created CALCITE-4529:
-------------------------------
Summary:
JoinUnionTransposeRule规则里string字段在join里会被转为varchar导致Cannot add expression of
different type to set
Key: CALCITE-4529
URL: https://issues.apache.org/jira/browse/CALCITE-4529
Project: Calcite
Issue Type: Bug
Components: core
Affects Versions: 1.24.0
Reporter: panhua
Attachments: image-2021-03-09-23-10-48-118.png
原始sql:select r1.deptno from (select * from hr.emps e1 union all select * from
hr.emps e2) r1,
hr.emps r2
使用CoreRules.JOIN_LEFT_UNION_TRANSPOSE规则
使用到的bean
!image-2021-03-09-23-10-48-118.png!
报错日志：
java.lang.AssertionError: Cannot add expression of different type to set:
set type is RecordType(JavaType(class java.lang.Integer) empid,
{color:#FF0000}VARCHAR ename,{color} JavaType(class java.lang.Long) sal,
JavaType(class java.lang.Integer) deptno, JavaType(class java.lang.Integer)
empid0,{color:#FF0000} JavaType(class java.lang.String) ename0,{color}
JavaType(class java.lang.Long) sal0, JavaType(class java.lang.Integer) deptno0)
NOT NULL
expression type is RecordType(JavaType(class java.lang.Integer) empid,
{color:#ff8b00}VARCHAR ename{color}, JavaType(class java.lang.Long) sal,
JavaType(class java.lang.Integer) deptno, JavaType(class java.lang.Integer)
empid0, {color:#ffab00}VARCHAR ename0{color}, JavaType(class java.lang.Long)
sal0, JavaType(class java.lang.Integer) deptno0) NOT NULL
set is
rel#26:LogicalJoin.NONE.[](left=HepRelVertex#25,right=HepRelVertex#20,condition=true,joinType=inner)
expression is LogicalUnion(all=[true])
LogicalJoin(condition=[true], joinType=[inner])
LogicalProject(empid=[$0], ename=[$1], sal=[$2], deptno=[$3])
LogicalTableScan(table=[[hr, emps]])
LogicalTableScan(table=[[hr, emps]])
LogicalJoin(condition=[true], joinType=[inner])
LogicalProject(empid=[$0], ename=[$1], sal=[$2], deptno=[$3])
LogicalTableScan(table=[[hr, emps]])
LogicalTableScan(table=[[hr, emps]])
报错堆栈：
at
org.apache.calcite.plan.RelOptUtil.verifyTypeEquivalence(RelOptUtil.java:381)
at
org.apache.calcite.plan.RelOptUtil.verifyTypeEquivalence(RelOptUtil.java:381)
at org.apache.calcite.plan.hep.HepRuleCall.transformTo(HepRuleCall.java:59) at
org.apache.calcite.plan.RelOptRuleCall.transformTo(RelOptRuleCall.java:268) at
org.apache.calcite.plan.RelOptRuleCall.transformTo(RelOptRuleCall.java:283) at
org.apache.calcite.rel.rules.JoinUnionTransposeRule.onMatch(JoinUnionTransposeRule.java:115)
at
org.apache.calcite.plan.AbstractRelOptPlanner.fireRule(AbstractRelOptPlanner.java:333)
at org.apache.calcite.plan.hep.HepPlanner.applyRule(HepPlanner.java:541) at
org.apache.calcite.plan.hep.HepPlanner.applyRules(HepPlanner.java:406) at
org.apache.calcite.plan.hep.HepPlanner.executeInstruction(HepPlanner.java:271)
at
org.apache.calcite.plan.hep.HepInstruction$RuleCollection.execute(HepInstruction.java:74)
at org.apache.calcite.plan.hep.HepPlanner.executeProgram(HepPlanner.java:202)
at org.apache.calcite.plan.hep.HepPlanner.findBestExp(HepPlanner.java:189) at
com.ph.calcite.demo.TestQuery.ruleOpemiter(TestQuery.java:217) at
com.ph.calcite.demo.TestQuery.testJoinQuery4(TestQuery.java:242) at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:104)
at org.testng.internal.Invoker.invokeMethod(Invoker.java:645) at
org.testng.internal.Invoker.invokeTestMethod(Invoker.java:851) at
org.testng.internal.Invoker.invokeTestMethods(Invoker.java:1177) at
org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:129)
at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:112) at
org.testng.TestRunner.privateRun(TestRunner.java:756) at
org.testng.TestRunner.run(TestRunner.java:610) at
org.testng.SuiteRunner.runTest(SuiteRunner.java:387) at
org.testng.SuiteRunner.runSequentially(SuiteRunner.java:382) at
org.testng.SuiteRunner.privateRun(SuiteRunner.java:340) at
org.testng.SuiteRunner.run(SuiteRunner.java:289) at
org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52) at
org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:86) at
org.testng.TestNG.runSuitesSequentially(TestNG.java:1293) at
org.testng.TestNG.runSuitesLocally(TestNG.java:1218) at
org.testng.TestNG.runSuites(TestNG.java:1133) at
org.testng.TestNG.run(TestNG.java:1104) at
com.intellij.rt.testng.IDEARemoteTestNG.run(IDEARemoteTestNG.java:66) at
com.intellij.rt.testng.RemoteTestNGStarter.main(RemoteTestNGStarter.java:110)
期望：能正常transformTo
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
