[FLINK-13534] Unable to query Hive table with decimal column

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.9.0
• Fix Version/s: 1.9.1, 1.10.0
• Component/s: Connectors / Hive
• Labels: pull-request-available
• Assignee: Rui Li
• Reporter: Rui Li
• Created: 01/Aug/19 12:28
• Updated: 27/Aug/19 04:09
• Resolved: 13/Aug/19 21:39

Description

Hit the following exception when access a Hive table with decimal column:

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)

Issue Links

• contains: FLINK-13549 Unable to query Hive table with char or varchar columns
• requires: FLINK-13495 blink-planner should support decimal precision to table source
• links to: GitHub Pull Request #9390