Hi, Would it be possible to have the Fix Version/s of the Jira issue FLINK-37222 [1] updated to reflect the fix has been backported to into release-1.20?
This issue is closed as fixed in version 2.1.0 only, so it is not reflected in changes expected. In the next maintenance release 1.20.2 [2] Thank you [1] https://issues.apache.org/jira/projects/FLINK/issues/FLINK-37222 [2] https://issues.apache.org/jira/projects/FLINK/versions/12355442 Regards, Sebastien Pereira On 24/01/2025, 18:03, "Zakelly Lan (Jira)" <j...@apache.org> wrote: Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: quoted-printable ----------------------------------- Summary: Table planner exception when sql client submit job Key: FLINK-37222 URL: 3Dhttps:= __issues.apache.org_jira_browse_FLINK-2D37222&d=3DDwICaQ&c=3DBSDicqBQBDjDI9= RkVyTcHQ&r=3D0sZs1KZEg0CpfaYnaTDNBZAJABwYYOpaIlO5A6RouwU&m=3DLTVOndZRcYbe_7= iA0taZwPU5lPkg0ycLvOuPmnH8t9KOS-i3ZEfP6s1ygOBXIVYS&s=3Dox6iPVnL6yk32OJdYBhI= NMhJj2nZ00AX0-6B_LrHcpc&e=3D=20 Project: Flink Issue Type: Bug Components: Table SQL / Planner Affects Versions: 2.0.0 Reporter: Zakelly Lan When testing [Nexmark|3Dhttps:= __github.com_nexmark_nexmark&d=3DDwICaQ&c=3DBSDicqBQBDjDI9RkVyTcHQ&r=3D0sZs= 1KZEg0CpfaYnaTDNBZAJABwYYOpaIlO5A6RouwU&m=3DLTVOndZRcYbe_7iA0taZwPU5lPkg0yc= LvOuPmnH8t9KOS-i3ZEfP6s1ygOBXIVYS&s=3DLWif9yD8hCX4fdV2EgRBGQI2HdhthLNgmhSq3= TcIStc&e=3D ] on release-2.0 branch, a table planner related exception thro= wn by the sql client: {code:java} // Omit some stacktraces before .... Caused by: org.apache.flink.table.gateway.service.utils.SqlExecutionExcepti= on: Failed to execute the operation d3516bc9-44c1-428e-ac10-2fb0ddd0c825. at org.apache.flink.table.gateway.service.operation.OperationManager$Opera= tion.processThrowable(OperationManager.java:415) at org.apache.flink.table.gateway.service.operation.OperationManager$Opera= tion.lambda$run$0(OperationManager.java:268) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors= .java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors= .java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolE= xecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPool= Executor.java:628) ... 1 more Caused by: java.lang.AssertionError: Sql optimization: Assertion error: Rel= ational expression rel#714:LogicalProject.NONE.any.None: 0.[NONE].[NONE](in= put=3DLogicalAggregate#712,exprs=3D[$2, $1]) belongs to a different planner= than is currently being used. at org.apache.flink.table.planner.plan.optimize.program.FlinkVolcanoProgra= m.optimize(FlinkVolcanoProgram.scala:79) at org.apache.flink.table.planner.plan.optimize.program.FlinkChainedProgra= m.$anonfun$optimize$1(FlinkChainedProgram.scala:59) at scala.collection.TraversableOnce$folder$1.apply(TraversableOnce.scala:1= 96) at scala.collection.TraversableOnce$folder$1.apply(TraversableOnce.scala:1= 94) at scala.collection.Iterator.foreach(Iterator.scala:943) at scala.collection.Iterator.foreach$(Iterator.scala:943) at scala.collection.AbstractIterator.foreach(Iterator.scala:1431) at scala.collection.IterableLike.foreach(IterableLike.scala:74) at scala.collection.IterableLike.foreach$(IterableLike.scala:73) at scala.collection.AbstractIterable.foreach(Iterable.scala:56) at scala.collection.TraversableOnce.foldLeft(TraversableOnce.scala:199) at scala.collection.TraversableOnce.foldLeft$(TraversableOnce.scala:192) at scala.collection.AbstractTraversable.foldLeft(Traversable.scala:108) at org.apache.flink.table.planner.plan.optimize.program.FlinkChainedProgra= m.optimize(FlinkChainedProgram.scala:55) at org.apache.flink.table.planner.plan.optimize.StreamCommonSubGraphBasedO= ptimizer.optimizeTree(StreamCommonSubGraphBasedOptimizer.scala:196) at org.apache.flink.table.planner.plan.optimize.StreamCommonSubGraphBasedO= ptimizer.optimizeSinkBlocks(StreamCommonSubGraphBasedOptimizer.scala:83) at org.apache.flink.table.planner.plan.optimize.StreamCommonSubGraphBasedO= ptimizer.doOptimize(StreamCommonSubGraphBasedOptimizer.scala:118) at org.apache.flink.table.planner.plan.optimize.CommonSubGraphBasedOptimiz= er.optimize(CommonSubGraphBasedOptimizer.scala:87) at org.apache.flink.table.planner.delegation.PlannerBase.optimize(PlannerB= ase.scala:390) at org.apache.flink.table.planner.delegation.PlannerBase.translate(Planner= Base.scala:183) at org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(Tabl= eEnvironmentImpl.java:1352) at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInterna= l(TableEnvironmentImpl.java:930) at org.apache.flink.table.gateway.service.operation.OperationExecutor.call= ModifyOperations(OperationExecutor.java:662) at org.apache.flink.table.gateway.service.operation.OperationExecutor.exec= uteOperation(OperationExecutor.java:500) at org.apache.flink.table.gateway.service.operation.OperationExecutor.exec= uteStatement(OperationExecutor.java:262) at org.apache.flink.table.gateway.service.operation.OperationExecutor.exec= uteStatement(OperationExecutor.java:217) at org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$exe= cuteStatement$1(SqlGatewayServiceImpl.java:221) at org.apache.flink.table.gateway.service.operation.OperationManager.lambd= a$submitOperation$1(OperationManager.java:120) at org.apache.flink.table.gateway.service.operation.OperationManager$Opera= tion.lambda$run$0(OperationManager.java:259) ... 7 more Caused by: java.lang.AssertionError: Relational expression rel#714:LogicalP= roject.NONE.any.None: 0.[NONE].[NONE](input=3DLogicalAggregate#712,exprs=3D= [$2, $1]) belongs to a different planner than is currently being used. at org.apache.calcite.plan.volcano.VolcanoPlanner.registerImpl(VolcanoPlan= ner.java:1248) at org.apache.calcite.plan.volcano.VolcanoPlanner.register(VolcanoPlanner.= java:598) at org.apache.calcite.plan.volcano.VolcanoPlanner.ensureRegistered(Volcano= Planner.java:613) at org.apache.calcite.plan.volcano.VolcanoPlanner.ensureRegistered(Volcano= Planner.java:95) at org.apache.calcite.rel.AbstractRelNode.onRegister(AbstractRelNode.java:= 273) at org.apache.calcite.plan.volcano.VolcanoPlanner.registerImpl(VolcanoPlan= ner.java:1271) at org.apache.calcite.plan.volcano.VolcanoPlanner.register(VolcanoPlanner.= java:598) at org.apache.calcite.plan.volcano.VolcanoPlanner.ensureRegistered(Volcano= Planner.java:613) at org.apache.calcite.plan.volcano.VolcanoPlanner.ensureRegistered(Volcano= Planner.java:95) at org.apache.calcite.rel.AbstractRelNode.onRegister(AbstractRelNode.java:= 273) at org.apache.calcite.plan.volcano.VolcanoPlanner.registerImpl(VolcanoPlan= ner.java:1271) at org.apache.calcite.plan.volcano.VolcanoPlanner.register(VolcanoPlanner.= java:598) at org.apache.calcite.plan.volcano.VolcanoPlanner.ensureRegistered(Volcano= Planner.java:613) at org.apache.calcite.plan.volcano.VolcanoPlanner.ensureRegistered(Volcano= Planner.java:95) at org.apache.calcite.rel.AbstractRelNode.onRegister(AbstractRelNode.java:= 273) at org.apache.calcite.plan.volcano.VolcanoPlanner.registerImpl(VolcanoPlan= ner.java:1271) at org.apache.calcite.plan.volcano.VolcanoPlanner.register(VolcanoPlanner.= java:598) at org.apache.calcite.plan.volcano.VolcanoPlanner.ensureRegistered(Volcano= Planner.java:613) at org.apache.calcite.plan.volcano.VolcanoPlanner.changeTraits(VolcanoPlan= ner.java:498) at org.apache.calcite.tools.Programs$RuleSetProgram.run(Programs.java:314) at org.apache.flink.table.planner.plan.optimize.program.FlinkVolcanoProgra= m.optimize(FlinkVolcanoProgram.scala:62) ... 35 more {code} I've tested on many commits and identified the commit https://urldefense.pr= oofpoint.com/v2/url?u=3Dhttps-3A__github.com_apache_flink_pull_25952&d=3DDw= ICaQ&c=3DBSDicqBQBDjDI9RkVyTcHQ&r=3D0sZs1KZEg0CpfaYnaTDNBZAJABwYYOpaIlO5A6R= ouwU&m=3DLTVOndZRcYbe_7iA0taZwPU5lPkg0ycLvOuPmnH8t9KOS-i3ZEfP6s1ygOBXIVYS&s= =3DZs5Q8rrSZUrwD6Ua4Y7gGcGOfCFbgHsk1F8epXcczIg&e=3D may cause this. By rev= erting this commit on release-2.0, the problem solved. -- This message was sent by Atlassian Jira (v8.20.10#820010) Unless otherwise stated above: Compagnie IBM France Siège Social : 17, avenue de l'Europe, 92275 Bois-Colombes Cedex RCS Nanterre 552 118 465 Forme Sociale : S.A.S. Capital Social : 664 614 175,50 € SIRET : 552 118 465 03644 - Code NAF 6203Z
