Jeff Zhang created FLINK-13423:
----------------------------------
Summary: Unable to find aggregation function in hive 1
Key: FLINK-13423
URL:
https://issues.apache.org/jira/browse/FLINK-13423 Project: Flink
Issue Type: Improvement
Components: Connectors / Hive
Affects Versions: 1.9.0
Reporter: Jeff Zhang
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)
Locked
