Jeff Zhang created FLINK-13152: ---------------------------------- Summary: Unable to run query when using HiveCatalog and DataSet api Key: FLINK-13152 URL: https://issues.apache.org/jira/browse/FLINK-13152 Project: Flink Issue Type: Bug Reporter: Jeff Zhang
{code:java} ERROR [2019-07-08 22:09:22,200] ({ParallelScheduler-Worker-1} FlinkSqlInterrpeter.java[runSqlList]:107) - Fail to run sql:select * from a org.apache.flink.table.api.TableException: Cannot generate a valid execution plan for the given query: FlinkLogicalTableSourceScan(table=[[hive, default, a]], fields=[tt], source=[HiveTableSource(tt)]) This exception indicates that the query uses an unsupported SQL feature. Please check the documentation for the set of currently supported SQL features. at org.apache.flink.table.plan.Optimizer.runVolcanoPlanner(Optimizer.scala:245) at org.apache.flink.table.plan.Optimizer.optimizePhysicalPlan(Optimizer.scala:170) at org.apache.flink.table.plan.BatchOptimizer.optimize(BatchOptimizer.scala:57) at org.apache.flink.table.api.internal.BatchTableEnvImpl.translate(BatchTableEnvImpl.scala:258) at org.apache.flink.table.api.scala.internal.BatchTableEnvironmentImpl.toDataSet(BatchTableEnvironmentImpl.scala:66){code} This is the exception I hit, and the below is code to reproduce the issue. I suspect it is because I am using DataSet and HiveCatalog together {code:java} def showTable(table: Table): String = { val columnNames: Array[String] = table.getSchema.getFieldNames val dsRow: DataSet[Row] = btenv.toDataSet[Row](table) val rows = dsRow.first(maxResult).collect() }{code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)