[
https://issues.apache.org/jira/browse/FLINK-29587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29587:
-----------------------------------
Labels: pull-request-available (was: )
> Fail to generate code for SearchOperator
> ------------------------------------------
>
> Key: FLINK-29587
> URL: https://issues.apache.org/jira/browse/FLINK-29587
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner, Table SQL / Runtime
> Reporter: luoyuxia
> Priority: Major
> Labels: pull-request-available
>
> Can be reproduced with the following code with Hive dialect
> {code:java}
> // hive dialect
> tableEnv.executeSql("create table table1 (id int, val string, val1 string,
> dimid int)");
> tableEnv.executeSql("create table table3 (id int)");
> CollectionUtil.iteratorToList(
> tableEnv.executeSql(
> "select table1.id, table1.val, table1.val1 from
> table1 left semi join"
> + " table3 on table1.dimid = table3.id and
> table3.id = 100 where table1.dimid = 200")
> .collect());{code}
> The plan is
> {code:java}
> LogicalSink(table=[*anonymous_collect$1*], fields=[id, val, val1])
> LogicalProject(id=[$0], val=[$1], val1=[$2])
> LogicalFilter(condition=[=($3, 200)])
> LogicalJoin(condition=[AND(=($3, $4), =($4, 100))], joinType=[semi])
> LogicalTableScan(table=[[test-catalog, default, table1]])
> LogicalTableScan(table=[[test-catalog, default,
> table3]])BatchPhysicalSink(table=[*anonymous_collect$1*], fields=[id, val,
> val1])
> BatchPhysicalNestedLoopJoin(joinType=[LeftSemiJoin], where=[$f1],
> select=[id, val, val1], build=[right])
> BatchPhysicalCalc(select=[id, val, val1], where=[=(dimid, 200)])
> BatchPhysicalTableSourceScan(table=[[test-catalog, default, table1]],
> fields=[id, val, val1, dimid])
> BatchPhysicalExchange(distribution=[broadcast])
> BatchPhysicalCalc(select=[SEARCH(id, Sarg[]) AS $f1])
> BatchPhysicalTableSourceScan(table=[[test-catalog, default, table3]],
> fields=[id]) {code}
>
> But it'll throw exception when generate code for it.
> The exception is
>
>
> {code:java}
> java.util.NoSuchElementException
> at
> com.google.common.collect.ImmutableRangeSet.span(ImmutableRangeSet.java:203)
> at org.apache.calcite.util.Sarg.isComplementedPoints(Sarg.java:148)
> at
> org.apache.flink.table.planner.codegen.calls.SearchOperatorGen$.generateSearch(SearchOperatorGen.scala:87)
> at
> org.apache.flink.table.planner.codegen.ExprCodeGenerator.visitCall(ExprCodeGenerator.scala:474)
> at
> org.apache.flink.table.planner.codegen.ExprCodeGenerator.visitCall(ExprCodeGenerator.scala:57)
> at org.apache.calcite.rex.RexCall.accept(RexCall.java:174)
> at
> org.apache.flink.table.planner.codegen.ExprCodeGenerator.generateExpression(ExprCodeGenerator.scala:143)
> at
> org.apache.flink.table.planner.codegen.CalcCodeGenerator$.$anonfun$generateProcessCode$4(CalcCodeGenerator.scala:140)
> at
> scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
> at
> scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:58)
> at
> scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:51)
> at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)
> at scala.collection.TraversableLike.map(TraversableLike.scala:233)
> at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
> at scala.collection.AbstractTraversable.map(Traversable.scala:104)
> at
> org.apache.flink.table.planner.codegen.CalcCodeGenerator$.produceProjectionCode$1(CalcCodeGenerator.scala:140)
> at
> org.apache.flink.table.planner.codegen.CalcCodeGenerator$.generateProcessCode(CalcCodeGenerator.scala:164)
> at
> org.apache.flink.table.planner.codegen.CalcCodeGenerator$.generateCalcOperator(CalcCodeGenerator.scala:49)
> at
> org.apache.flink.table.planner.codegen.CalcCodeGenerator.generateCalcOperator(CalcCodeGenerator.scala)
> at
> org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecCalc.translateToPlanInternal(CommonExecCalc.java:100)
> at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:158)
> at
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:257)
> at
> org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecExchange.translateToPlanInternal(BatchExecExchange.java:136)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
