[
https://issues.apache.org/jira/browse/FLINK-13423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-13423:
----------------------------------
Assignee: Rui Li
> Unable to find function in hive 1
> ---------------------------------
>
> Key: FLINK-13423
> URL: https://issues.apache.org/jira/browse/FLINK-13423
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Hive
> Affects Versions: 1.9.0
> Reporter: Jeff Zhang
> Assignee: Rui Li
> Priority: Blocker
>
> I hit the following error when I try to use count in sql on hive1
> {code:java}
> btenv.sqlQuery("select count(1) from date_dim").toDataSet[Row].print(){code}
> {code:java}
> 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{code}
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
