[FLINK-13423] Unable to find function in hive 1

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.9.0
• Fix Version/s: 1.9.0
• Component/s: Connectors / Hive
• Labels: pull-request-available
• Assignee: Rui Li
• Reporter: Jeff Zhang
• Created: 25/Jul/19 08:27
• Updated: 01/Aug/19 10:58
• Resolved: 01/Aug/19 04:09

Description

I hit the following error when I try to use count in sql on hive1

btenv.sqlQuery("select count(1) from date_dim").toDataSet[Row].print()

org.apache.flink.table.api.ValidationException: SQL validation failed. Failed to get function tpcds_text_2.COUNT
at org.apache.flink.table.calcite.FlinkPlannerImpl.validate(FlinkPlannerImpl.scala:127)
at org.apache.flink.table.api.internal.TableEnvImpl.sqlQuery(TableEnvImpl.scala:427)
... 30 elided
Caused by: org.apache.flink.table.catalog.exceptions.CatalogException: Failed to get function tpcds_text_2.COUNT
at org.apache.flink.table.catalog.hive.HiveCatalog.getFunction(HiveCatalog.java:1033)
at org.apache.flink.table.catalog.FunctionCatalog.lookupFunction(FunctionCatalog.java:167)
at org.apache.flink.table.catalog.FunctionCatalogOperatorTable.lookupOperatorOverloads(FunctionCatalogOperatorTable.java:74)
at org.apache.calcite.sql.util.ChainedSqlOperatorTable.lookupOperatorOverloads(ChainedSqlOperatorTable.java:73)
at org.apache.calcite.sql.validate.SqlValidatorImpl.performUnconditionalRewrites(SqlValidatorImpl.java:1183)
at org.apache.calcite.sql.validate.SqlValidatorImpl.performUnconditionalRewrites(SqlValidatorImpl.java:1198)
at org.apache.calcite.sql.validate.SqlValidatorImpl.performUnconditionalRewrites(SqlValidatorImpl.java:1168)
at org.apache.calcite.sql.validate.SqlValidatorImpl.validateScopedExpression(SqlValidatorImpl.java:925)
at org.apache.calcite.sql.validate.SqlValidatorImpl.validate(SqlValidatorImpl.java:639)
at org.apache.flink.table.calcite.FlinkPlannerImpl.validate(FlinkPlannerImpl.scala:123)
... 31 more

Issue Links

• links to: GitHub Pull Request #9279