[
https://issues.apache.org/jira/browse/CALCITE-4529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325606#comment-17325606
]
jibiyr commented on CALCITE-4529:
---------------------------------
[~Chunwei Lei] [~julianhyde],Dear community
I debug and find when JoinUnionTransposeRule on Match,
It will register LogicalJoin(left=LogicalUnion, right=LogicalScan) to pre
RelSubset which the digest is LogicalUnion(LogicalJoin, LogicalScan).
then confirm both rel and RelSubset have the same rowType
However, LogicalUnion calls
deriveRowType->leastRestrictive(inputRowTypes)->leastRestrictiveSqlType. so the
JavaType(String) will be converted to Varchar(SqlType). but LogicalJoin is not,
it is still JavaType(String).
So an exception occurred.I think the behavior is not expected.
> In JoinUnionTransposeRule rule, the string field will be converted to varchar
> in join, resulting in cannot address 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
> Priority: Minor
> Attachments: image-2021-03-09-23-10-48-118.png
>
>
> original sql:select r1.deptno from (select * from hr.emps e1 union all select
> * from hr.emps e2) r1,
> hr.emps r2
>
>
> use CoreRules.JOIN_LEFT_UNION_TRANSPOSE rule
> used bean
> !image-2021-03-09-23-10-48-118.png!
>
> error log：
> 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]])
>
> errror stack：
> 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)
>
> expect：It can pass normally transformTo
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
