[
https://issues.apache.org/jira/browse/FLINK-20349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238795#comment-17238795
]
Rui Li commented on FLINK-20349:
--------------------------------
Stack trace is:
{noformat}
java.lang.IllegalStateException: A conflict is detected. This is unexpected.
at
org.apache.flink.table.planner.plan.processors.utils.InputOrderCalculator.resolveInputPriorityConflict(InputOrderCalculator.java:170)
at
org.apache.flink.table.planner.plan.processors.utils.InputPriorityGraphGenerator.addTopologyEdges(InputPriorityGraphGenerator.java:167)
at
org.apache.flink.table.planner.plan.processors.utils.InputPriorityGraphGenerator.updateTopologyGraph(InputPriorityGraphGenerator.java:150)
at
org.apache.flink.table.planner.plan.processors.utils.InputPriorityGraphGenerator.access$100(InputPriorityGraphGenerator.java:85)
at
org.apache.flink.table.planner.plan.processors.utils.InputPriorityGraphGenerator$1.visitNode(InputPriorityGraphGenerator.java:124)
at
org.apache.flink.table.planner.plan.nodes.exec.AbstractExecNodeExactlyOnceVisitor.visit(AbstractExecNodeExactlyOnceVisitor.java:41)
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNode$class.accept(ExecNode.scala:102)
at
org.apache.flink.table.planner.plan.nodes.physical.batch.BatchExecJoinBase.accept(BatchExecJoinBase.scala:42)
at
org.apache.flink.table.planner.plan.processors.utils.InputPriorityGraphGenerator.lambda$createTopologyGraph$1(InputPriorityGraphGenerator.java:127)
at java.util.Collections$SingletonList.forEach(Collections.java:4822)
at
org.apache.flink.table.planner.plan.processors.utils.InputPriorityGraphGenerator.createTopologyGraph(InputPriorityGraphGenerator.java:127)
at
org.apache.flink.table.planner.plan.processors.utils.InputOrderCalculator.calculate(InputOrderCalculator.java:63)
at
org.apache.flink.table.planner.plan.processors.MultipleInputNodeCreationProcessor.createBatchMultipleInputNode(MultipleInputNodeCreationProcessor.java:502)
at
org.apache.flink.table.planner.plan.processors.MultipleInputNodeCreationProcessor.createMultipleInputNode(MultipleInputNodeCreationProcessor.java:470)
at
org.apache.flink.table.planner.plan.processors.MultipleInputNodeCreationProcessor.getMultipleInputNode(MultipleInputNodeCreationProcessor.java:438)
at
org.apache.flink.table.planner.plan.processors.MultipleInputNodeCreationProcessor.getMultipleInputNode(MultipleInputNodeCreationProcessor.java:433)
at
org.apache.flink.table.planner.plan.processors.MultipleInputNodeCreationProcessor.getMultipleInputNode(MultipleInputNodeCreationProcessor.java:433)
at
org.apache.flink.table.planner.plan.processors.MultipleInputNodeCreationProcessor.getMultipleInputNode(MultipleInputNodeCreationProcessor.java:433)
at
org.apache.flink.table.planner.plan.processors.MultipleInputNodeCreationProcessor.getMultipleInputNode(MultipleInputNodeCreationProcessor.java:433)
at
org.apache.flink.table.planner.plan.processors.MultipleInputNodeCreationProcessor.getMultipleInputNode(MultipleInputNodeCreationProcessor.java:433)
at
org.apache.flink.table.planner.plan.processors.MultipleInputNodeCreationProcessor.createMultipleInputNodes(MultipleInputNodeCreationProcessor.java:420)
at
org.apache.flink.table.planner.plan.processors.MultipleInputNodeCreationProcessor.process(MultipleInputNodeCreationProcessor.java:93)
at
org.apache.flink.table.planner.delegation.BatchPlanner$$anonfun$translateToExecNodePlan$1.apply(BatchPlanner.scala:77)
at
org.apache.flink.table.planner.delegation.BatchPlanner$$anonfun$translateToExecNodePlan$1.apply(BatchPlanner.scala:77)
at
scala.collection.TraversableOnce$$anonfun$foldLeft$1.apply(TraversableOnce.scala:157)
at
scala.collection.TraversableOnce$$anonfun$foldLeft$1.apply(TraversableOnce.scala:157)
at scala.collection.Iterator$class.foreach(Iterator.scala:891)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at
scala.collection.TraversableOnce$class.foldLeft(TraversableOnce.scala:157)
at scala.collection.AbstractTraversable.foldLeft(Traversable.scala:104)
at
org.apache.flink.table.planner.delegation.BatchPlanner.translateToExecNodePlan(BatchPlanner.scala:76)
at
org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:166)
{noformat}
> Query fails with "A conflict is detected. This is unexpected."
> --------------------------------------------------------------
>
> Key: FLINK-20349
> URL: https://issues.apache.org/jira/browse/FLINK-20349
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Reporter: Rui Li
> Priority: Major
> Fix For: 1.13.0
>
>
> The test case to reproduce:
> {code}
> @Test
> public void test() throws Exception {
> tableEnv.executeSql("create table src(key string,val string)");
> tableEnv.executeSql("SELECT sum(char_length(src5.src1_value))
> FROM " +
> "(SELECT src3.*, src4.val as src4_value,
> src4.key as src4_key FROM src src4 JOIN " +
> "(SELECT src2.*, src1.key as src1_key, src1.val
> as src1_value FROM src src1 JOIN src src2 ON src1.key = src2.key) src3 " +
> "ON src3.src1_key = src4.key) src5").collect();
> }
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
