Rui Li created FLINK-13534:
------------------------------
Summary: Unable to query Hive table with decimal column
Key: FLINK-13534
URL: https://issues.apache.org/jira/browse/FLINK-13534
Project: Flink
Issue Type: Bug
Reporter: Rui Li
Hit the following exception when access a Hive table with decimal column:
{noformat}
Caused by: org.apache.flink.table.api.TableException: TableSource of type
org.apache.flink.batch.connectors.hive.HiveTableSource returned a DataSet of
data type ROW<`x` LEGACY(BigDecimal)> that does not match with the data type
ROW<`x` DECIMAL(10, 0)> declared by the TableSource.getProducedDataType()
method. Please validate the implementation of the TableSource.
at
org.apache.flink.table.plan.nodes.dataset.BatchTableSourceScan.translateToPlan(BatchTableSourceScan.scala:118)
at
org.apache.flink.table.api.internal.BatchTableEnvImpl.translate(BatchTableEnvImpl.scala:303)
at
org.apache.flink.table.api.internal.BatchTableEnvImpl.translate(BatchTableEnvImpl.scala:281)
at
org.apache.flink.table.api.internal.BatchTableEnvImpl.writeToSink(BatchTableEnvImpl.scala:117)
at
org.apache.flink.table.api.internal.TableEnvImpl.insertInto(TableEnvImpl.scala:564)
at
org.apache.flink.table.api.internal.TableEnvImpl.insertInto(TableEnvImpl.scala:516)
at
org.apache.flink.table.api.internal.BatchTableEnvImpl.insertInto(BatchTableEnvImpl.scala:59)
at org.apache.flink.table.api.internal.TableImpl.insertInto(TableImpl.java:428)
{noformat}
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
