[jira] [Updated] (FLINK-12999) Can't generate valid execution plan for "SELECT uuid() FROM (VALUES(1,2,3)) T(a, b, c)"
[ https://issues.apache.org/jira/browse/FLINK-12999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12999: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was: auto-deprioritized-major auto-unassigned stale-minor) Priority: Not a Priority (was: Minor) This issue was labeled "stale-minor" 7 days ago and has not received any updates so it is being deprioritized. If this ticket is actually Minor, please raise the priority and ask a committer to assign you the issue or revive the public discussion. > Can't generate valid execution plan for "SELECT uuid() FROM (VALUES(1,2,3)) > T(a, b, c)" > --- > > Key: FLINK-12999 > URL: https://issues.apache.org/jira/browse/FLINK-12999 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner >Affects Versions: 1.9.0 >Reporter: Zhenghua Gao >Priority: Not a Priority > Labels: auto-deprioritized-major, auto-deprioritized-minor, > auto-unassigned > > The ERROR message is: > > org.apache.flink.table.api.TableException: Cannot generate a valid execution > plan for the given query: > LogicalSink(fields=[EXPR$0]) > +- LogicalProject(EXPR$0=[UUID()]) > +- LogicalValues(tuples=[[\{ 1, 2, 3 }]]) > This exception indicates that the query uses an unsupported SQL feature. > Please check the documentation for the set of currently supported SQL > features. > at > org.apache.flink.table.plan.optimize.program.FlinkVolcanoProgram.optimize(FlinkVolcanoProgram.scala:72) > at > org.apache.flink.table.plan.optimize.program.FlinkChainedProgram$$anonfun$optimize$1.apply(FlinkChainedProgram.scala:62) > at > org.apache.flink.table.plan.optimize.program.FlinkChainedProgram$$anonfun$optimize$1.apply(FlinkChainedProgram.scala:58) > 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.plan.optimize.program.FlinkChainedProgram.optimize(FlinkChainedProgram.scala:57) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.optimizeTree(BatchCommonSubGraphBasedOptimizer.scala:82) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.org$apache$flink$table$plan$optimize$BatchCommonSubGraphBasedOptimizer$$optimizeBlock(BatchCommonSubGraphBasedOptimizer.scala:51) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer$$anonfun$doOptimize$1.apply(BatchCommonSubGraphBasedOptimizer.scala:39) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer$$anonfun$doOptimize$1.apply(BatchCommonSubGraphBasedOptimizer.scala:39) > at scala.collection.immutable.List.foreach(List.scala:392) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.doOptimize(BatchCommonSubGraphBasedOptimizer.scala:39) > at > org.apache.flink.table.plan.optimize.CommonSubGraphBasedOptimizer.optimize(CommonSubGraphBasedOptimizer.scala:65) > at > org.apache.flink.table.api.TableEnvironment.optimize(TableEnvironment.scala:251) > at > org.apache.flink.table.api.TableEnvironment.compileToExecNodePlan(TableEnvironment.scala:200) > at > org.apache.flink.table.api.TableEnvironment.compile(TableEnvironment.scala:184) > at > org.apache.flink.table.api.TableEnvironment.generateStreamGraph(TableEnvironment.scala:155) > at > org.apache.flink.table.api.BatchTableEnvironment.execute(BatchTableEnvironment.scala:93) > at > org.apache.flink.table.api.TableEnvironment.execute(TableEnvironment.scala:136) > at > org.apache.flink.table.runtime.utils.BatchTableEnvUtil$.collect(BatchTableEnvUtil.scala:55) > at > org.apache.flink.table.runtime.utils.TableUtil$.collectSink(TableUtil.scala:60) > at > org.apache.flink.table.runtime.utils.TableUtil$.collect(TableUtil.scala:41) > at > org.apache.flink.table.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:308) > at > org.apache.flink.table.runtime.utils.BatchTestBase.check(BatchTestBase.scala:164) > at > org.apache.flink.table.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:103) > at > org.apache.flink.table.runtime.batch.sql.ValuesITCase.test(ValuesITCase.scala:38) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
[jira] [Updated] (FLINK-12999) Can't generate valid execution plan for "SELECT uuid() FROM (VALUES(1,2,3)) T(a, b, c)"
[ https://issues.apache.org/jira/browse/FLINK-12999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12999: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was: auto-deprioritized-major auto-unassigned) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its development. I see this issues has been marked as Minor but is unassigned and neither itself nor its Sub-Tasks have been updated for 180 days. I have gone ahead and marked it "stale-minor". If this ticket is still Minor, please either assign yourself or give an update. Afterwards, please remove the label or in 7 days the issue will be deprioritized. > Can't generate valid execution plan for "SELECT uuid() FROM (VALUES(1,2,3)) > T(a, b, c)" > --- > > Key: FLINK-12999 > URL: https://issues.apache.org/jira/browse/FLINK-12999 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner >Affects Versions: 1.9.0 >Reporter: Zhenghua Gao >Priority: Minor > Labels: auto-deprioritized-major, auto-unassigned, stale-minor > > The ERROR message is: > > org.apache.flink.table.api.TableException: Cannot generate a valid execution > plan for the given query: > LogicalSink(fields=[EXPR$0]) > +- LogicalProject(EXPR$0=[UUID()]) > +- LogicalValues(tuples=[[\{ 1, 2, 3 }]]) > This exception indicates that the query uses an unsupported SQL feature. > Please check the documentation for the set of currently supported SQL > features. > at > org.apache.flink.table.plan.optimize.program.FlinkVolcanoProgram.optimize(FlinkVolcanoProgram.scala:72) > at > org.apache.flink.table.plan.optimize.program.FlinkChainedProgram$$anonfun$optimize$1.apply(FlinkChainedProgram.scala:62) > at > org.apache.flink.table.plan.optimize.program.FlinkChainedProgram$$anonfun$optimize$1.apply(FlinkChainedProgram.scala:58) > 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.plan.optimize.program.FlinkChainedProgram.optimize(FlinkChainedProgram.scala:57) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.optimizeTree(BatchCommonSubGraphBasedOptimizer.scala:82) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.org$apache$flink$table$plan$optimize$BatchCommonSubGraphBasedOptimizer$$optimizeBlock(BatchCommonSubGraphBasedOptimizer.scala:51) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer$$anonfun$doOptimize$1.apply(BatchCommonSubGraphBasedOptimizer.scala:39) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer$$anonfun$doOptimize$1.apply(BatchCommonSubGraphBasedOptimizer.scala:39) > at scala.collection.immutable.List.foreach(List.scala:392) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.doOptimize(BatchCommonSubGraphBasedOptimizer.scala:39) > at > org.apache.flink.table.plan.optimize.CommonSubGraphBasedOptimizer.optimize(CommonSubGraphBasedOptimizer.scala:65) > at > org.apache.flink.table.api.TableEnvironment.optimize(TableEnvironment.scala:251) > at > org.apache.flink.table.api.TableEnvironment.compileToExecNodePlan(TableEnvironment.scala:200) > at > org.apache.flink.table.api.TableEnvironment.compile(TableEnvironment.scala:184) > at > org.apache.flink.table.api.TableEnvironment.generateStreamGraph(TableEnvironment.scala:155) > at > org.apache.flink.table.api.BatchTableEnvironment.execute(BatchTableEnvironment.scala:93) > at > org.apache.flink.table.api.TableEnvironment.execute(TableEnvironment.scala:136) > at > org.apache.flink.table.runtime.utils.BatchTableEnvUtil$.collect(BatchTableEnvUtil.scala:55) > at > org.apache.flink.table.runtime.utils.TableUtil$.collectSink(TableUtil.scala:60) > at > org.apache.flink.table.runtime.utils.TableUtil$.collect(TableUtil.scala:41) > at > org.apache.flink.table.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:308) > at > org.apache.flink.table.runtime.utils.BatchTestBase.check(BatchTestBase.scala:164) > at > org.apache.flink.table.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:103) > at >
[jira] [Updated] (FLINK-12999) Can't generate valid execution plan for "SELECT uuid() FROM (VALUES(1,2,3)) T(a, b, c)"
[ https://issues.apache.org/jira/browse/FLINK-12999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12999: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major) Priority: Minor (was: Major) This issue was labeled "stale-major" 7 ago and has not received any updates so it is being deprioritized. If this ticket is actually Major, please raise the priority and ask a committer to assign you the issue or revive the public discussion. > Can't generate valid execution plan for "SELECT uuid() FROM (VALUES(1,2,3)) > T(a, b, c)" > --- > > Key: FLINK-12999 > URL: https://issues.apache.org/jira/browse/FLINK-12999 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner >Affects Versions: 1.9.0 >Reporter: Zhenghua Gao >Priority: Minor > Labels: auto-deprioritized-major, auto-unassigned > > The ERROR message is: > > org.apache.flink.table.api.TableException: Cannot generate a valid execution > plan for the given query: > LogicalSink(fields=[EXPR$0]) > +- LogicalProject(EXPR$0=[UUID()]) > +- LogicalValues(tuples=[[\{ 1, 2, 3 }]]) > This exception indicates that the query uses an unsupported SQL feature. > Please check the documentation for the set of currently supported SQL > features. > at > org.apache.flink.table.plan.optimize.program.FlinkVolcanoProgram.optimize(FlinkVolcanoProgram.scala:72) > at > org.apache.flink.table.plan.optimize.program.FlinkChainedProgram$$anonfun$optimize$1.apply(FlinkChainedProgram.scala:62) > at > org.apache.flink.table.plan.optimize.program.FlinkChainedProgram$$anonfun$optimize$1.apply(FlinkChainedProgram.scala:58) > 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.plan.optimize.program.FlinkChainedProgram.optimize(FlinkChainedProgram.scala:57) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.optimizeTree(BatchCommonSubGraphBasedOptimizer.scala:82) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.org$apache$flink$table$plan$optimize$BatchCommonSubGraphBasedOptimizer$$optimizeBlock(BatchCommonSubGraphBasedOptimizer.scala:51) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer$$anonfun$doOptimize$1.apply(BatchCommonSubGraphBasedOptimizer.scala:39) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer$$anonfun$doOptimize$1.apply(BatchCommonSubGraphBasedOptimizer.scala:39) > at scala.collection.immutable.List.foreach(List.scala:392) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.doOptimize(BatchCommonSubGraphBasedOptimizer.scala:39) > at > org.apache.flink.table.plan.optimize.CommonSubGraphBasedOptimizer.optimize(CommonSubGraphBasedOptimizer.scala:65) > at > org.apache.flink.table.api.TableEnvironment.optimize(TableEnvironment.scala:251) > at > org.apache.flink.table.api.TableEnvironment.compileToExecNodePlan(TableEnvironment.scala:200) > at > org.apache.flink.table.api.TableEnvironment.compile(TableEnvironment.scala:184) > at > org.apache.flink.table.api.TableEnvironment.generateStreamGraph(TableEnvironment.scala:155) > at > org.apache.flink.table.api.BatchTableEnvironment.execute(BatchTableEnvironment.scala:93) > at > org.apache.flink.table.api.TableEnvironment.execute(TableEnvironment.scala:136) > at > org.apache.flink.table.runtime.utils.BatchTableEnvUtil$.collect(BatchTableEnvUtil.scala:55) > at > org.apache.flink.table.runtime.utils.TableUtil$.collectSink(TableUtil.scala:60) > at > org.apache.flink.table.runtime.utils.TableUtil$.collect(TableUtil.scala:41) > at > org.apache.flink.table.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:308) > at > org.apache.flink.table.runtime.utils.BatchTestBase.check(BatchTestBase.scala:164) > at > org.apache.flink.table.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:103) > at > org.apache.flink.table.runtime.batch.sql.ValuesITCase.test(ValuesITCase.scala:38) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > at
[jira] [Updated] (FLINK-12999) Can't generate valid execution plan for "SELECT uuid() FROM (VALUES(1,2,3)) T(a, b, c)"
[ https://issues.apache.org/jira/browse/FLINK-12999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12999: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its development. I see this issues has been marked as Major but is unassigned and neither itself nor its Sub-Tasks have been updated for 30 days. I have gone ahead and added a "stale-major" to the issue". If this ticket is a Major, please either assign yourself or give an update. Afterwards, please remove the label or in 7 days the issue will be deprioritized. > Can't generate valid execution plan for "SELECT uuid() FROM (VALUES(1,2,3)) > T(a, b, c)" > --- > > Key: FLINK-12999 > URL: https://issues.apache.org/jira/browse/FLINK-12999 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner >Affects Versions: 1.9.0 >Reporter: Zhenghua Gao >Priority: Major > Labels: auto-unassigned, stale-major > > The ERROR message is: > > org.apache.flink.table.api.TableException: Cannot generate a valid execution > plan for the given query: > LogicalSink(fields=[EXPR$0]) > +- LogicalProject(EXPR$0=[UUID()]) > +- LogicalValues(tuples=[[\{ 1, 2, 3 }]]) > This exception indicates that the query uses an unsupported SQL feature. > Please check the documentation for the set of currently supported SQL > features. > at > org.apache.flink.table.plan.optimize.program.FlinkVolcanoProgram.optimize(FlinkVolcanoProgram.scala:72) > at > org.apache.flink.table.plan.optimize.program.FlinkChainedProgram$$anonfun$optimize$1.apply(FlinkChainedProgram.scala:62) > at > org.apache.flink.table.plan.optimize.program.FlinkChainedProgram$$anonfun$optimize$1.apply(FlinkChainedProgram.scala:58) > 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.plan.optimize.program.FlinkChainedProgram.optimize(FlinkChainedProgram.scala:57) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.optimizeTree(BatchCommonSubGraphBasedOptimizer.scala:82) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.org$apache$flink$table$plan$optimize$BatchCommonSubGraphBasedOptimizer$$optimizeBlock(BatchCommonSubGraphBasedOptimizer.scala:51) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer$$anonfun$doOptimize$1.apply(BatchCommonSubGraphBasedOptimizer.scala:39) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer$$anonfun$doOptimize$1.apply(BatchCommonSubGraphBasedOptimizer.scala:39) > at scala.collection.immutable.List.foreach(List.scala:392) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.doOptimize(BatchCommonSubGraphBasedOptimizer.scala:39) > at > org.apache.flink.table.plan.optimize.CommonSubGraphBasedOptimizer.optimize(CommonSubGraphBasedOptimizer.scala:65) > at > org.apache.flink.table.api.TableEnvironment.optimize(TableEnvironment.scala:251) > at > org.apache.flink.table.api.TableEnvironment.compileToExecNodePlan(TableEnvironment.scala:200) > at > org.apache.flink.table.api.TableEnvironment.compile(TableEnvironment.scala:184) > at > org.apache.flink.table.api.TableEnvironment.generateStreamGraph(TableEnvironment.scala:155) > at > org.apache.flink.table.api.BatchTableEnvironment.execute(BatchTableEnvironment.scala:93) > at > org.apache.flink.table.api.TableEnvironment.execute(TableEnvironment.scala:136) > at > org.apache.flink.table.runtime.utils.BatchTableEnvUtil$.collect(BatchTableEnvUtil.scala:55) > at > org.apache.flink.table.runtime.utils.TableUtil$.collectSink(TableUtil.scala:60) > at > org.apache.flink.table.runtime.utils.TableUtil$.collect(TableUtil.scala:41) > at > org.apache.flink.table.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:308) > at > org.apache.flink.table.runtime.utils.BatchTestBase.check(BatchTestBase.scala:164) > at > org.apache.flink.table.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:103) > at > org.apache.flink.table.runtime.batch.sql.ValuesITCase.test(ValuesITCase.scala:38) > at
[jira] [Updated] (FLINK-12999) Can't generate valid execution plan for "SELECT uuid() FROM (VALUES(1,2,3)) T(a, b, c)"
[ https://issues.apache.org/jira/browse/FLINK-12999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12999: --- Labels: auto-unassigned (was: stale-assigned) > Can't generate valid execution plan for "SELECT uuid() FROM (VALUES(1,2,3)) > T(a, b, c)" > --- > > Key: FLINK-12999 > URL: https://issues.apache.org/jira/browse/FLINK-12999 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner >Affects Versions: 1.9.0 >Reporter: Zhenghua Gao >Assignee: godfrey he >Priority: Major > Labels: auto-unassigned > > The ERROR message is: > > org.apache.flink.table.api.TableException: Cannot generate a valid execution > plan for the given query: > LogicalSink(fields=[EXPR$0]) > +- LogicalProject(EXPR$0=[UUID()]) > +- LogicalValues(tuples=[[\{ 1, 2, 3 }]]) > This exception indicates that the query uses an unsupported SQL feature. > Please check the documentation for the set of currently supported SQL > features. > at > org.apache.flink.table.plan.optimize.program.FlinkVolcanoProgram.optimize(FlinkVolcanoProgram.scala:72) > at > org.apache.flink.table.plan.optimize.program.FlinkChainedProgram$$anonfun$optimize$1.apply(FlinkChainedProgram.scala:62) > at > org.apache.flink.table.plan.optimize.program.FlinkChainedProgram$$anonfun$optimize$1.apply(FlinkChainedProgram.scala:58) > 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.plan.optimize.program.FlinkChainedProgram.optimize(FlinkChainedProgram.scala:57) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.optimizeTree(BatchCommonSubGraphBasedOptimizer.scala:82) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.org$apache$flink$table$plan$optimize$BatchCommonSubGraphBasedOptimizer$$optimizeBlock(BatchCommonSubGraphBasedOptimizer.scala:51) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer$$anonfun$doOptimize$1.apply(BatchCommonSubGraphBasedOptimizer.scala:39) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer$$anonfun$doOptimize$1.apply(BatchCommonSubGraphBasedOptimizer.scala:39) > at scala.collection.immutable.List.foreach(List.scala:392) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.doOptimize(BatchCommonSubGraphBasedOptimizer.scala:39) > at > org.apache.flink.table.plan.optimize.CommonSubGraphBasedOptimizer.optimize(CommonSubGraphBasedOptimizer.scala:65) > at > org.apache.flink.table.api.TableEnvironment.optimize(TableEnvironment.scala:251) > at > org.apache.flink.table.api.TableEnvironment.compileToExecNodePlan(TableEnvironment.scala:200) > at > org.apache.flink.table.api.TableEnvironment.compile(TableEnvironment.scala:184) > at > org.apache.flink.table.api.TableEnvironment.generateStreamGraph(TableEnvironment.scala:155) > at > org.apache.flink.table.api.BatchTableEnvironment.execute(BatchTableEnvironment.scala:93) > at > org.apache.flink.table.api.TableEnvironment.execute(TableEnvironment.scala:136) > at > org.apache.flink.table.runtime.utils.BatchTableEnvUtil$.collect(BatchTableEnvUtil.scala:55) > at > org.apache.flink.table.runtime.utils.TableUtil$.collectSink(TableUtil.scala:60) > at > org.apache.flink.table.runtime.utils.TableUtil$.collect(TableUtil.scala:41) > at > org.apache.flink.table.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:308) > at > org.apache.flink.table.runtime.utils.BatchTestBase.check(BatchTestBase.scala:164) > at > org.apache.flink.table.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:103) > at > org.apache.flink.table.runtime.batch.sql.ValuesITCase.test(ValuesITCase.scala:38) > 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.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50) > at >
[jira] [Updated] (FLINK-12999) Can't generate valid execution plan for "SELECT uuid() FROM (VALUES(1,2,3)) T(a, b, c)"
[ https://issues.apache.org/jira/browse/FLINK-12999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12999: --- Labels: stale-assigned (was: ) > Can't generate valid execution plan for "SELECT uuid() FROM (VALUES(1,2,3)) > T(a, b, c)" > --- > > Key: FLINK-12999 > URL: https://issues.apache.org/jira/browse/FLINK-12999 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner >Affects Versions: 1.9.0 >Reporter: Zhenghua Gao >Assignee: godfrey he >Priority: Major > Labels: stale-assigned > > The ERROR message is: > > org.apache.flink.table.api.TableException: Cannot generate a valid execution > plan for the given query: > LogicalSink(fields=[EXPR$0]) > +- LogicalProject(EXPR$0=[UUID()]) > +- LogicalValues(tuples=[[\{ 1, 2, 3 }]]) > This exception indicates that the query uses an unsupported SQL feature. > Please check the documentation for the set of currently supported SQL > features. > at > org.apache.flink.table.plan.optimize.program.FlinkVolcanoProgram.optimize(FlinkVolcanoProgram.scala:72) > at > org.apache.flink.table.plan.optimize.program.FlinkChainedProgram$$anonfun$optimize$1.apply(FlinkChainedProgram.scala:62) > at > org.apache.flink.table.plan.optimize.program.FlinkChainedProgram$$anonfun$optimize$1.apply(FlinkChainedProgram.scala:58) > 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.plan.optimize.program.FlinkChainedProgram.optimize(FlinkChainedProgram.scala:57) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.optimizeTree(BatchCommonSubGraphBasedOptimizer.scala:82) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.org$apache$flink$table$plan$optimize$BatchCommonSubGraphBasedOptimizer$$optimizeBlock(BatchCommonSubGraphBasedOptimizer.scala:51) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer$$anonfun$doOptimize$1.apply(BatchCommonSubGraphBasedOptimizer.scala:39) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer$$anonfun$doOptimize$1.apply(BatchCommonSubGraphBasedOptimizer.scala:39) > at scala.collection.immutable.List.foreach(List.scala:392) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.doOptimize(BatchCommonSubGraphBasedOptimizer.scala:39) > at > org.apache.flink.table.plan.optimize.CommonSubGraphBasedOptimizer.optimize(CommonSubGraphBasedOptimizer.scala:65) > at > org.apache.flink.table.api.TableEnvironment.optimize(TableEnvironment.scala:251) > at > org.apache.flink.table.api.TableEnvironment.compileToExecNodePlan(TableEnvironment.scala:200) > at > org.apache.flink.table.api.TableEnvironment.compile(TableEnvironment.scala:184) > at > org.apache.flink.table.api.TableEnvironment.generateStreamGraph(TableEnvironment.scala:155) > at > org.apache.flink.table.api.BatchTableEnvironment.execute(BatchTableEnvironment.scala:93) > at > org.apache.flink.table.api.TableEnvironment.execute(TableEnvironment.scala:136) > at > org.apache.flink.table.runtime.utils.BatchTableEnvUtil$.collect(BatchTableEnvUtil.scala:55) > at > org.apache.flink.table.runtime.utils.TableUtil$.collectSink(TableUtil.scala:60) > at > org.apache.flink.table.runtime.utils.TableUtil$.collect(TableUtil.scala:41) > at > org.apache.flink.table.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:308) > at > org.apache.flink.table.runtime.utils.BatchTestBase.check(BatchTestBase.scala:164) > at > org.apache.flink.table.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:103) > at > org.apache.flink.table.runtime.batch.sql.ValuesITCase.test(ValuesITCase.scala:38) > 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.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50) > at > org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
[jira] [Updated] (FLINK-12999) Can't generate valid execution plan for "SELECT uuid() FROM (VALUES(1,2,3)) T(a, b, c)"
[ https://issues.apache.org/jira/browse/FLINK-12999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao updated FLINK-12999: - Summary: Can't generate valid execution plan for "SELECT uuid() FROM (VALUES(1,2,3)) T(a, b, c)" (was: Can't generate valid execution plan for "SELECT uuid() FROM VALUES(1,2,3) T(a, b, c)") > Can't generate valid execution plan for "SELECT uuid() FROM (VALUES(1,2,3)) > T(a, b, c)" > --- > > Key: FLINK-12999 > URL: https://issues.apache.org/jira/browse/FLINK-12999 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner >Affects Versions: 1.9.0 >Reporter: Zhenghua Gao >Assignee: godfrey he >Priority: Major > > The ERROR message is: > > org.apache.flink.table.api.TableException: Cannot generate a valid execution > plan for the given query: > LogicalSink(fields=[EXPR$0]) > +- LogicalProject(EXPR$0=[UUID()]) > +- LogicalValues(tuples=[[\{ 1, 2, 3 }]]) > This exception indicates that the query uses an unsupported SQL feature. > Please check the documentation for the set of currently supported SQL > features. > at > org.apache.flink.table.plan.optimize.program.FlinkVolcanoProgram.optimize(FlinkVolcanoProgram.scala:72) > at > org.apache.flink.table.plan.optimize.program.FlinkChainedProgram$$anonfun$optimize$1.apply(FlinkChainedProgram.scala:62) > at > org.apache.flink.table.plan.optimize.program.FlinkChainedProgram$$anonfun$optimize$1.apply(FlinkChainedProgram.scala:58) > 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.plan.optimize.program.FlinkChainedProgram.optimize(FlinkChainedProgram.scala:57) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.optimizeTree(BatchCommonSubGraphBasedOptimizer.scala:82) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.org$apache$flink$table$plan$optimize$BatchCommonSubGraphBasedOptimizer$$optimizeBlock(BatchCommonSubGraphBasedOptimizer.scala:51) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer$$anonfun$doOptimize$1.apply(BatchCommonSubGraphBasedOptimizer.scala:39) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer$$anonfun$doOptimize$1.apply(BatchCommonSubGraphBasedOptimizer.scala:39) > at scala.collection.immutable.List.foreach(List.scala:392) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.doOptimize(BatchCommonSubGraphBasedOptimizer.scala:39) > at > org.apache.flink.table.plan.optimize.CommonSubGraphBasedOptimizer.optimize(CommonSubGraphBasedOptimizer.scala:65) > at > org.apache.flink.table.api.TableEnvironment.optimize(TableEnvironment.scala:251) > at > org.apache.flink.table.api.TableEnvironment.compileToExecNodePlan(TableEnvironment.scala:200) > at > org.apache.flink.table.api.TableEnvironment.compile(TableEnvironment.scala:184) > at > org.apache.flink.table.api.TableEnvironment.generateStreamGraph(TableEnvironment.scala:155) > at > org.apache.flink.table.api.BatchTableEnvironment.execute(BatchTableEnvironment.scala:93) > at > org.apache.flink.table.api.TableEnvironment.execute(TableEnvironment.scala:136) > at > org.apache.flink.table.runtime.utils.BatchTableEnvUtil$.collect(BatchTableEnvUtil.scala:55) > at > org.apache.flink.table.runtime.utils.TableUtil$.collectSink(TableUtil.scala:60) > at > org.apache.flink.table.runtime.utils.TableUtil$.collect(TableUtil.scala:41) > at > org.apache.flink.table.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:308) > at > org.apache.flink.table.runtime.utils.BatchTestBase.check(BatchTestBase.scala:164) > at > org.apache.flink.table.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:103) > at > org.apache.flink.table.runtime.batch.sql.ValuesITCase.test(ValuesITCase.scala:38) > 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 >
[jira] [Updated] (FLINK-12999) Can't generate valid execution plan for "SELECT uuid() FROM VALUES(1,2,3) T(a, b, c)"
[ https://issues.apache.org/jira/browse/FLINK-12999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao updated FLINK-12999: - Summary: Can't generate valid execution plan for "SELECT uuid() FROM VALUES(1,2,3) T(a, b, c)" (was: Can't generate valid execution plan for "SELECT uuid() FROM VALUES(1) T(a)") > Can't generate valid execution plan for "SELECT uuid() FROM VALUES(1,2,3) > T(a, b, c)" > - > > Key: FLINK-12999 > URL: https://issues.apache.org/jira/browse/FLINK-12999 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner >Affects Versions: 1.9.0 >Reporter: Zhenghua Gao >Assignee: godfrey he >Priority: Major > > The ERROR message is: > > org.apache.flink.table.api.TableException: Cannot generate a valid execution > plan for the given query: > LogicalSink(fields=[EXPR$0]) > +- LogicalProject(EXPR$0=[UUID()]) > +- LogicalValues(tuples=[[\{ 1, 2, 3 }]]) > This exception indicates that the query uses an unsupported SQL feature. > Please check the documentation for the set of currently supported SQL > features. > at > org.apache.flink.table.plan.optimize.program.FlinkVolcanoProgram.optimize(FlinkVolcanoProgram.scala:72) > at > org.apache.flink.table.plan.optimize.program.FlinkChainedProgram$$anonfun$optimize$1.apply(FlinkChainedProgram.scala:62) > at > org.apache.flink.table.plan.optimize.program.FlinkChainedProgram$$anonfun$optimize$1.apply(FlinkChainedProgram.scala:58) > 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.plan.optimize.program.FlinkChainedProgram.optimize(FlinkChainedProgram.scala:57) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.optimizeTree(BatchCommonSubGraphBasedOptimizer.scala:82) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.org$apache$flink$table$plan$optimize$BatchCommonSubGraphBasedOptimizer$$optimizeBlock(BatchCommonSubGraphBasedOptimizer.scala:51) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer$$anonfun$doOptimize$1.apply(BatchCommonSubGraphBasedOptimizer.scala:39) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer$$anonfun$doOptimize$1.apply(BatchCommonSubGraphBasedOptimizer.scala:39) > at scala.collection.immutable.List.foreach(List.scala:392) > at > org.apache.flink.table.plan.optimize.BatchCommonSubGraphBasedOptimizer.doOptimize(BatchCommonSubGraphBasedOptimizer.scala:39) > at > org.apache.flink.table.plan.optimize.CommonSubGraphBasedOptimizer.optimize(CommonSubGraphBasedOptimizer.scala:65) > at > org.apache.flink.table.api.TableEnvironment.optimize(TableEnvironment.scala:251) > at > org.apache.flink.table.api.TableEnvironment.compileToExecNodePlan(TableEnvironment.scala:200) > at > org.apache.flink.table.api.TableEnvironment.compile(TableEnvironment.scala:184) > at > org.apache.flink.table.api.TableEnvironment.generateStreamGraph(TableEnvironment.scala:155) > at > org.apache.flink.table.api.BatchTableEnvironment.execute(BatchTableEnvironment.scala:93) > at > org.apache.flink.table.api.TableEnvironment.execute(TableEnvironment.scala:136) > at > org.apache.flink.table.runtime.utils.BatchTableEnvUtil$.collect(BatchTableEnvUtil.scala:55) > at > org.apache.flink.table.runtime.utils.TableUtil$.collectSink(TableUtil.scala:60) > at > org.apache.flink.table.runtime.utils.TableUtil$.collect(TableUtil.scala:41) > at > org.apache.flink.table.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:308) > at > org.apache.flink.table.runtime.utils.BatchTestBase.check(BatchTestBase.scala:164) > at > org.apache.flink.table.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:103) > at > org.apache.flink.table.runtime.batch.sql.ValuesITCase.test(ValuesITCase.scala:38) > 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 >