You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2019/07/25 08:30:00 UTC
[jira] [Updated] (FLINK-13423) Unable to find function in hive 1
[ https://issues.apache.org/jira/browse/FLINK-13423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jeff Zhang updated FLINK-13423:
-------------------------------
Summary: Unable to find function in hive 1 (was: Unable to find aggregation function in hive 1)
> 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
> Priority: Major
>
> 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)