[jira] [Created] (FLINK-13534) Unable to query Hive table with decimal column

[Shang Yuanchun (Jira)]

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)