[
https://issues.apache.org/jira/browse/FLINK-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900601#comment-16900601
]
Rui Li commented on FLINK-13534:
--------------------------------
[~lzljs3620320] Just verified latest PR of FLINK-13495 fixes the issues of
reading decimal/char/varchar types in Hive connector (with some changes to Hive
source/sink). I'll submit a PR for this ticket once FLINK-13495 is in.
> 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
> Components: Connectors / Hive
> Reporter: Rui Li
> Priority: Major
>
> 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)
