[ https://issues.apache.org/jira/browse/FLINK-13423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kurt Young updated FLINK-13423: ------------------------------- Fix Version/s: 1.10.0 1.9.0 > 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 > Fix For: 1.9.0, 1.10.0 > > > 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)