Caused by: org.apache.flink.client.program.ProgramInvocationException: The main
method caused an error: SQL validation failed. Failed to get table column stats
of table cosldatacenter.ods_zyxx_coslzj_towing
at
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:114)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:242)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
... 10 more
Caused by: org.apache.flink.table.api.ValidationException: SQL validation
failed. Failed to get table column stats of table
cosldatacenter.ods_zyxx_coslzj_towing
at
org.apache.flink.table.planner.calcite.FlinkPlannerImpl.org$apache$flink$table$planner$calcite$FlinkPlannerImpl$$validate(FlinkPlannerImpl.scala:157)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.FlinkPlannerImpl.validate(FlinkPlannerImpl.scala:110)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.operations.SqlToOperationConverter.convert(SqlToOperationConverter.java:201)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.delegation.ParserImpl.parse(ParserImpl.java:101)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.delegation.hive.HiveParser.processCmd(HiveParser.java:284)
~[flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.delegation.hive.HiveParser.parse(HiveParser.java:217)
~[flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.api.internal.StatementSetImpl.addInsertSql(StatementSetImpl.java:51)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
com.meritdata.cloud.tempo.dw.flow.engine.app.ScriptEngine.scriptRunning(ScriptEngine.java:201)
~[tempo-dw-flow-engine-app-0.0.1-SNAPSHOT.jar:?]
at
com.meritdata.cloud.tempo.dw.flow.engine.app.ScriptEngine.execute(ScriptEngine.java:171)
~[tempo-dw-flow-engine-app-0.0.1-SNAPSHOT.jar:?]
at
com.meritdata.cloud.tempo.dw.flow.engine.app.ScriptEngine.main(ScriptEngine.java:128)
~[tempo-dw-flow-engine-app-0.0.1-SNAPSHOT.jar:?]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[?:1.8.0_141]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[?:1.8.0_141]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_141]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_141]
at
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:114)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:242)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
... 10 more
Caused by: org.apache.flink.table.catalog.exceptions.CatalogException: Failed
to get table column stats of table cosldatacenter.ods_zyxx_coslzj_towing
at
org.apache.flink.table.catalog.hive.HiveCatalog.getTableColumnStatistics(HiveCatalog.java:1635)
~[flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.catalog.DatabaseCalciteSchema.extractTableStats(DatabaseCalciteSchema.java:121)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.catalog.DatabaseCalciteSchema.getStatistic(DatabaseCalciteSchema.java:107)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.catalog.DatabaseCalciteSchema.lambda$getTable$0(DatabaseCalciteSchema.java:82)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at java.util.Optional.map(Optional.java:215) ~[?:1.8.0_141]
at
org.apache.flink.table.planner.catalog.DatabaseCalciteSchema.getTable(DatabaseCalciteSchema.java:77)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.jdbc.SimpleCalciteSchema.getImplicitTable(SimpleCalciteSchema.java:83)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.jdbc.CalciteSchema.getTable(CalciteSchema.java:289)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.EmptyScope.resolve_(EmptyScope.java:143)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.EmptyScope.resolveTable(EmptyScope.java:99)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.DelegatingScope.resolveTable(DelegatingScope.java:203)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.IdentifierNamespace.resolveImpl(IdentifierNamespace.java:112)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.IdentifierNamespace.validateImpl(IdentifierNamespace.java:184)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.AbstractNamespace.validate(AbstractNamespace.java:84)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateNamespace(SqlValidatorImpl.java:997)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateQuery(SqlValidatorImpl.java:975)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateFrom(SqlValidatorImpl.java:3085)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateFrom(SqlValidatorImpl.java:3070)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateJoin(SqlValidatorImpl.java:3132)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.FlinkCalciteSqlValidator.validateJoin(FlinkCalciteSqlValidator.java:117)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateFrom(SqlValidatorImpl.java:3076)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateJoin(SqlValidatorImpl.java:3132)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.FlinkCalciteSqlValidator.validateJoin(FlinkCalciteSqlValidator.java:117)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateFrom(SqlValidatorImpl.java:3076)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateSelect(SqlValidatorImpl.java:3335)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SelectNamespace.validateImpl(SelectNamespace.java:60)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.AbstractNamespace.validate(AbstractNamespace.java:84)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateNamespace(SqlValidatorImpl.java:997)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateQuery(SqlValidatorImpl.java:975)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at org.apache.calcite.sql.SqlSelect.validate(SqlSelect.java:232)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateScopedExpression(SqlValidatorImpl.java:952)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validate(SqlValidatorImpl.java:704)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.PreValidateReWriter$.rewriteSelect(PreValidateReWriter.scala:244)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.PreValidateReWriter$.rewriteSqlCall(PreValidateReWriter.scala:212)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.PreValidateReWriter$.appendPartitionAndNullsProjects(PreValidateReWriter.scala:190)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.PreValidateReWriter.visit(PreValidateReWriter.scala:55)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.PreValidateReWriter.visit(PreValidateReWriter.scala:47)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at org.apache.calcite.sql.SqlCall.accept(SqlCall.java:139)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.FlinkPlannerImpl.org$apache$flink$table$planner$calcite$FlinkPlannerImpl$$validate(FlinkPlannerImpl.scala:115)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.FlinkPlannerImpl.validate(FlinkPlannerImpl.scala:110)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.operations.SqlToOperationConverter.convert(SqlToOperationConverter.java:201)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.delegation.ParserImpl.parse(ParserImpl.java:101)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.delegation.hive.HiveParser.processCmd(HiveParser.java:284)
~[flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.delegation.hive.HiveParser.parse(HiveParser.java:217)
~[flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.api.internal.StatementSetImpl.addInsertSql(StatementSetImpl.java:51)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
com.meritdata.cloud.tempo.dw.flow.engine.app.ScriptEngine.scriptRunning(ScriptEngine.java:201)
~[tempo-dw-flow-engine-app-0.0.1-SNAPSHOT.jar:?]
at
com.meritdata.cloud.tempo.dw.flow.engine.app.ScriptEngine.execute(ScriptEngine.java:171)
~[tempo-dw-flow-engine-app-0.0.1-SNAPSHOT.jar:?]
at
com.meritdata.cloud.tempo.dw.flow.engine.app.ScriptEngine.main(ScriptEngine.java:128)
~[tempo-dw-flow-engine-app-0.0.1-SNAPSHOT.jar:?]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[?:1.8.0_141]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[?:1.8.0_141]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_141]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_141]
at
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:114)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:242)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
... 10 more
Caused by: org.apache.hadoop.hive.metastore.api.MetaException: Exception thrown
when executing query
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$get_table_statistics_req_result$get_table_statistics_req_resultStandardScheme.read(ThriftHiveMetastore.java)
~[flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar:1.13.1]
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$get_table_statistics_req_result$get_table_statistics_req_resultStandardScheme.read(ThriftHiveMetastore.java)
~[flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar:1.13.1]
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$get_table_statistics_req_result.read(ThriftHiveMetastore.java)
~[flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar:1.13.1]
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
~[flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar:1.13.1]
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_get_table_statistics_req(ThriftHiveMetastore.java:2971)
~[flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar:1.13.1]
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.get_table_statistics_req(ThriftHiveMetastore.java:2958)
~[flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar:1.13.1]
at
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.getTableColumnStatistics(HiveMetaStoreClient.java:1447)
~[flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar:1.13.1]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[?:1.8.0_141]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[?:1.8.0_141]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_141]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_141]
at
org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.invoke(RetryingMetaStoreClient.java:152)
~[flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar:1.13.1]
at com.sun.proxy.$Proxy45.getTableColumnStatistics(Unknown Source)
~[?:?]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[?:1.8.0_141]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[?:1.8.0_141]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_141]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_141]
at
org.apache.hadoop.hive.metastore.HiveMetaStoreClient$SynchronizedHandler.invoke(HiveMetaStoreClient.java:1988)
~[flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar:1.13.1]
at com.sun.proxy.$Proxy45.getTableColumnStatistics(Unknown Source)
~[?:?]
at
org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper.getTableColumnStatistics(HiveMetastoreClientWrapper.java:223)
~[flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.catalog.hive.HiveCatalog.getTableColumnStatistics(HiveCatalog.java:1623)
~[flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.catalog.DatabaseCalciteSchema.extractTableStats(DatabaseCalciteSchema.java:121)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.catalog.DatabaseCalciteSchema.getStatistic(DatabaseCalciteSchema.java:107)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.catalog.DatabaseCalciteSchema.lambda$getTable$0(DatabaseCalciteSchema.java:82)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at java.util.Optional.map(Optional.java:215) ~[?:1.8.0_141]
at
org.apache.flink.table.planner.catalog.DatabaseCalciteSchema.getTable(DatabaseCalciteSchema.java:77)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.jdbc.SimpleCalciteSchema.getImplicitTable(SimpleCalciteSchema.java:83)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.jdbc.CalciteSchema.getTable(CalciteSchema.java:289)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.EmptyScope.resolve_(EmptyScope.java:143)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.EmptyScope.resolveTable(EmptyScope.java:99)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.DelegatingScope.resolveTable(DelegatingScope.java:203)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.IdentifierNamespace.resolveImpl(IdentifierNamespace.java:112)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.IdentifierNamespace.validateImpl(IdentifierNamespace.java:184)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.AbstractNamespace.validate(AbstractNamespace.java:84)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateNamespace(SqlValidatorImpl.java:997)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateQuery(SqlValidatorImpl.java:975)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateFrom(SqlValidatorImpl.java:3085)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateFrom(SqlValidatorImpl.java:3070)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateJoin(SqlValidatorImpl.java:3132)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.FlinkCalciteSqlValidator.validateJoin(FlinkCalciteSqlValidator.java:117)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateFrom(SqlValidatorImpl.java:3076)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateJoin(SqlValidatorImpl.java:3132)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.FlinkCalciteSqlValidator.validateJoin(FlinkCalciteSqlValidator.java:117)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateFrom(SqlValidatorImpl.java:3076)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateSelect(SqlValidatorImpl.java:3335)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SelectNamespace.validateImpl(SelectNamespace.java:60)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.AbstractNamespace.validate(AbstractNamespace.java:84)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateNamespace(SqlValidatorImpl.java:997)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateQuery(SqlValidatorImpl.java:975)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at org.apache.calcite.sql.SqlSelect.validate(SqlSelect.java:232)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validateScopedExpression(SqlValidatorImpl.java:952)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.calcite.sql.validate.SqlValidatorImpl.validate(SqlValidatorImpl.java:704)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.PreValidateReWriter$.rewriteSelect(PreValidateReWriter.scala:244)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.PreValidateReWriter$.rewriteSqlCall(PreValidateReWriter.scala:212)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.PreValidateReWriter$.appendPartitionAndNullsProjects(PreValidateReWriter.scala:190)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.PreValidateReWriter.visit(PreValidateReWriter.scala:55)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.PreValidateReWriter.visit(PreValidateReWriter.scala:47)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at org.apache.calcite.sql.SqlCall.accept(SqlCall.java:139)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.FlinkPlannerImpl.org$apache$flink$table$planner$calcite$FlinkPlannerImpl$$validate(FlinkPlannerImpl.scala:115)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.calcite.FlinkPlannerImpl.validate(FlinkPlannerImpl.scala:110)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.operations.SqlToOperationConverter.convert(SqlToOperationConverter.java:201)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.delegation.ParserImpl.parse(ParserImpl.java:101)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.delegation.hive.HiveParser.processCmd(HiveParser.java:284)
~[flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.delegation.hive.HiveParser.parse(HiveParser.java:217)
~[flink-sql-connector-hive-1.2.2_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.api.internal.StatementSetImpl.addInsertSql(StatementSetImpl.java:51)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
com.meritdata.cloud.tempo.dw.flow.engine.app.ScriptEngine.scriptRunning(ScriptEngine.java:201)
~[tempo-dw-flow-engine-app-0.0.1-SNAPSHOT.jar:?]
at
com.meritdata.cloud.tempo.dw.flow.engine.app.ScriptEngine.execute(ScriptEngine.java:171)
~[tempo-dw-flow-engine-app-0.0.1-SNAPSHOT.jar:?]
at
com.meritdata.cloud.tempo.dw.flow.engine.app.ScriptEngine.main(ScriptEngine.java:128)
~[tempo-dw-flow-engine-app-0.0.1-SNAPSHOT.jar:?]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[?:1.8.0_141]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[?:1.8.0_141]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_141]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_141]
at
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:114)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:242)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
... 10 more
