Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
1.13.3
-
None
-
None
-
offical docker image, flink:1.13.3-scala_2.12
Description
Flink SQL> insert into `wide_order` (`user_id`, `row_num`, `sum`) > select `t`.`receiver_user_id`, `t`.`rowNum`, `t`.`total` > from (select `t`.`receiver_user_id`, `t`.`total`, ROW_NUMBER() OVER (ORDER BY total desc) as `rowNum` > from (select `order_view`.`receiver_user_id`, sum(`order_view`.`total`) as `total` > from `order_view` where create_time > '2021-11-01 00:24:55.453' > group by `order_view`.`receiver_user_id`) `t`) `t` > where `rowNum` <= 10000; Exception in thread "main" org.apache.flink.table.client.SqlClientException: Unexpected exception. This is a bug. Please consider filing an issue. at org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:201) at org.apache.flink.table.client.SqlClient.main(SqlClient.java:161) Caused by: java.lang.NoSuchMethodError: org.apache.flink.table.catalog.CatalogManager$TableLookupResult.getCatalog()Ljava/util/Optional; at org.apache.flink.table.planner.catalog.DatabaseCalciteSchema.extractTableStats(DatabaseCalciteSchema.java:106) at org.apache.flink.table.planner.catalog.DatabaseCalciteSchema.getStatistic(DatabaseCalciteSchema.java:90) at org.apache.flink.table.planner.catalog.DatabaseCalciteSchema.lambda$getTable$0(DatabaseCalciteSchema.java:79) at java.util.Optional.map(Optional.java:215) at org.apache.flink.table.planner.catalog.DatabaseCalciteSchema.getTable(DatabaseCalciteSchema.java:74) at org.apache.calcite.jdbc.SimpleCalciteSchema.getImplicitTable(SimpleCalciteSchema.java:83) at org.apache.calcite.jdbc.CalciteSchema.getTable(CalciteSchema.java:289) at org.apache.calcite.sql.validate.SqlValidatorUtil.getTableEntryFrom(SqlValidatorUtil.java:1059) at org.apache.calcite.sql.validate.SqlValidatorUtil.getTableEntry(SqlValidatorUtil.java:1016) at org.apache.calcite.prepare.CalciteCatalogReader.getTable(CalciteCatalogReader.java:119) at org.apache.flink.table.planner.plan.FlinkCalciteCatalogReader.getTable(FlinkCalciteCatalogReader.java:86) at org.apache.flink.table.planner.calcite.PreValidateReWriter$.appendPartitionAndNullsProjects(PreValidateReWriter.scala:116) at org.apache.flink.table.planner.calcite.PreValidateReWriter.visit(PreValidateReWriter.scala:56) at org.apache.flink.table.planner.calcite.PreValidateReWriter.visit(PreValidateReWriter.scala:47) at org.apache.calcite.sql.SqlCall.accept(SqlCall.java:139) at org.apache.flink.table.planner.calcite.FlinkPlannerImpl.org$apache$flink$table$planner$calcite$FlinkPlannerImpl$$validate(FlinkPlannerImpl.scala:113) at org.apache.flink.table.planner.calcite.FlinkPlannerImpl.validate(FlinkPlannerImpl.scala:107) at org.apache.flink.table.planner.operations.SqlToOperationConverter.convert(SqlToOperationConverter.java:205) at org.apache.flink.table.planner.delegation.ParserImpl.parse(ParserImpl.java:101) at org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$parseStatement$1(LocalExecutor.java:176) at org.apache.flink.table.client.gateway.context.ExecutionContext.wrapClassLoader(ExecutionContext.java:90) at org.apache.flink.table.client.gateway.local.LocalExecutor.parseStatement(LocalExecutor.java:176) at org.apache.flink.table.client.cli.CliClient.parseCommand(CliClient.java:385) at org.apache.flink.table.client.cli.CliClient.executeStatement(CliClient.java:326) at org.apache.flink.table.client.cli.CliClient.executeInteractive(CliClient.java:297) at org.apache.flink.table.client.cli.CliClient.executeInInteractiveMode(CliClient.java:221) at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:151) at org.apache.flink.table.client.SqlClient.start(SqlClient.java:95) at org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:187) ... 1 more Shutting down the session... done.