schema信息如下： CREATE TABLE x.ods.ods_binlog_test_trip_create_t_order_1 ( _type STRING, order_no STRING, order_time STRING, dt as TO_TIMESTAMP(order_time), proctime as PROCTIME(), WATERMARK FOR dt AS dt - INTERVAL '5' SECOND ) WITH ( 'connector.type' = 'kafka', 'connector.properties.bootstrap.servers' = '*****', 'connector.properties.zookeeper.connect' = '*****', 'connector.version' = 'universal', 'format.type' = 'json', 'connector.properties.group.id' = 'testGroup', 'connector.startup-mode' = 'group-offsets', 'connector.topic' = 'ods-test_trip_create-t_order' ) ________________________________ 发件人: godfrey he <godfre...@gmail.com> 发送时间: 2020年7月28日 9:55 收件人: user-zh <user-zh@flink.apache.org> 主题: Re: flink1.11.0 执行sqlQuery时报NullPointException
hi 能给出详细的schema信息吗？ wind.fly....@outlook.com <wind.fly....@outlook.com> 于2020年7月27日周一 下午7:02写道： > 补充一下，执行的sql如下： > > select order_no, order_time from > x.ods.ods_binlog_test_trip_create_t_order_1 > > ________________________________ > 发件人: wind.fly....@outlook.com <wind.fly....@outlook.com> > 发送时间: 2020年7月27日 18:49 > 收件人: user-zh@flink.apache.org <user-zh@flink.apache.org> > 主题: flink1.11.0 执行sqlQuery时报NullPointException > > Hi,all： > 本人正在为公司之前基于flink1.10的gateway升级flink版本到1.11，用的hive > catalog，建表后，执行sqlQuery方法时报NullPointException，希望给出排错建议，具体报错信息如下： > Caused by: java.lang.NullPointerException > at java.util.Objects.requireNonNull(Objects.java:203) > at > org.apache.calcite.rel.metadata.RelMetadataQuery.<init>(RelMetadataQuery.java:141) > at > org.apache.calcite.rel.metadata.RelMetadataQuery.<init>(RelMetadataQuery.java:106) > at > org.apache.flink.table.planner.plan.metadata.FlinkRelMetadataQuery.<init>(FlinkRelMetadataQuery.java:73) > at > org.apache.flink.table.planner.plan.metadata.FlinkRelMetadataQuery.instance(FlinkRelMetadataQuery.java:52) > at > org.apache.flink.table.planner.calcite.FlinkRelOptClusterFactory$$anon$1.get(FlinkRelOptClusterFactory.scala:39) > at > org.apache.flink.table.planner.calcite.FlinkRelOptClusterFactory$$anon$1.get(FlinkRelOptClusterFactory.scala:38) > at > org.apache.calcite.plan.RelOptCluster.getMetadataQuery(RelOptCluster.java:178) > at > org.apache.calcite.rel.logical.LogicalProject.create(LogicalProject.java:118) > at > org.apache.calcite.rel.logical.LogicalProject.create(LogicalProject.java:111) > at > org.apache.calcite.rel.core.RelFactories$ProjectFactoryImpl.createProject(RelFactories.java:180) > at org.apache.calcite.tools.RelBuilder.project_(RelBuilder.java:1462) > at org.apache.calcite.tools.RelBuilder.project(RelBuilder.java:1256) > at org.apache.calcite.tools.RelBuilder.projectNamed(RelBuilder.java:1521) > at > org.apache.calcite.sql2rel.SqlToRelConverter.convertSelectList(SqlToRelConverter.java:4125) > at > org.apache.calcite.sql2rel.SqlToRelConverter.convertSelectImpl(SqlToRelConverter.java:685) > at > org.apache.calcite.sql2rel.SqlToRelConverter.convertSelect(SqlToRelConverter.java:642) > at > org.apache.calcite.sql2rel.SqlToRelConverter.convertQueryRecursive(SqlToRelConverter.java:3345) > at > org.apache.calcite.sql2rel.SqlToRelConverter.convertQuery(SqlToRelConverter.java:568) > at org.apache.flink.table.planner.calcite.FlinkPlannerImpl.org > $apache$flink$table$planner$calcite$FlinkPlannerImpl$$rel(FlinkPlannerImpl.scala:164) > at > org.apache.flink.table.planner.calcite.FlinkPlannerImpl.rel(FlinkPlannerImpl.scala:151) > at > org.apache.flink.table.planner.calcite.SqlExprToRexConverterImpl.convertToRexNodes(SqlExprToRexConverterImpl.java:81) > at > org.apache.flink.table.planner.calcite.SqlExprToRexConverterImpl.convertToRexNode(SqlExprToRexConverterImpl.java:73) > at > org.apache.flink.table.planner.delegation.ParserImpl.parseSqlExpression(ParserImpl.java:93) > at > org.apache.flink.table.api.internal.CatalogTableSchemaResolver.resolveExpressionDataType(CatalogTableSchemaResolver.java:119) > at > org.apache.flink.table.api.internal.CatalogTableSchemaResolver.resolve(CatalogTableSchemaResolver.java:83) > at > org.apache.flink.table.catalog.CatalogManager.resolveTableSchema(CatalogManager.java:380) > at > org.apache.flink.table.catalog.CatalogManager.getPermanentTable(CatalogManager.java:408) > at > org.apache.flink.table.catalog.CatalogManager.getTable(CatalogManager.java:375) > at > org.apache.flink.table.planner.catalog.DatabaseCalciteSchema.getTable(DatabaseCalciteSchema.java:75) > 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.EmptyScope.resolve_(EmptyScope.java:143) > at > org.apache.calcite.sql.validate.EmptyScope.resolveTable(EmptyScope.java:99) > at > org.apache.calcite.sql.validate.DelegatingScope.resolveTable(DelegatingScope.java:203) > at > org.apache.calcite.sql.validate.IdentifierNamespace.resolveImpl(IdentifierNamespace.java:112) > at > org.apache.calcite.sql.validate.IdentifierNamespace.validateImpl(IdentifierNamespace.java:184) > at > org.apache.calcite.sql.validate.AbstractNamespace.validate(AbstractNamespace.java:84) > at > org.apache.calcite.sql.validate.SqlValidatorImpl.validateNamespace(SqlValidatorImpl.java:1110) > at > org.apache.calcite.sql.validate.SqlValidatorImpl.validateQuery(SqlValidatorImpl.java:1084) > at > org.apache.calcite.sql.validate.SqlValidatorImpl.validateFrom(SqlValidatorImpl.java:3256) > at > org.apache.calcite.sql.validate.SqlValidatorImpl.validateFrom(SqlValidatorImpl.java:3238) > at > org.apache.calcite.sql.validate.SqlValidatorImpl.validateSelect(SqlValidatorImpl.java:3510) > at > org.apache.calcite.sql.validate.SelectNamespace.validateImpl(SelectNamespace.java:60) > at > org.apache.calcite.sql.validate.AbstractNamespace.validate(AbstractNamespace.java:84) > at > org.apache.calcite.sql.validate.SqlValidatorImpl.validateNamespace(SqlValidatorImpl.java:1110) > at > org.apache.calcite.sql.validate.SqlValidatorImpl.validateQuery(SqlValidatorImpl.java:1084) > at org.apache.calcite.sql.SqlSelect.validate(SqlSelect.java:232) > at > org.apache.calcite.sql.validate.SqlValidatorImpl.validateScopedExpression(SqlValidatorImpl.java:1059) > at > org.apache.calcite.sql.validate.SqlValidatorImpl.validate(SqlValidatorImpl.java:766) > at org.apache.flink.table.planner.calcite.FlinkPlannerImpl.org > $apache$flink$table$planner$calcite$FlinkPlannerImpl$$validate(FlinkPlannerImpl.scala:141) > ... 54 more >
