You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/09 06:18:00 UTC
[jira] [Updated] (FLINK-13438) Hive source/sink/udx should respect
the conversion class of DataType
[ https://issues.apache.org/jira/browse/FLINK-13438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jingsong Lee updated FLINK-13438:
---------------------------------
Parent: (was: FLINK-13285)
Issue Type: Bug (was: Sub-task)
> Hive source/sink/udx should respect the conversion class of DataType
> --------------------------------------------------------------------
>
> Key: FLINK-13438
> URL: https://issues.apache.org/jira/browse/FLINK-13438
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Hive
> Reporter: Caizhi Weng
> Assignee: Caizhi Weng
> Priority: Critical
> Labels: pull-request-available
> Fix For: 1.10.0
>
> Attachments: 0001-hive.patch
>
> Time Spent: 10m
> Remaining Estimate: 0h
>
> Similar to JDBC connectors, Hive connectors communicate with Flink framework using TableSchema, which contains DataType. As the time data read from and write to Hive connectors must be java.sql.* types and the default conversion class of our time data types are java.time.*, we have to fix Hive connector with DataTypes.DATE/TIME/TIMESTAMP support.
> But currently when reading tables from Hive, the table schema is created using Hive's schema, so the time types in the created schema will be sql time type not local time type. If user specifies a local time type in the table schema when creating a table in Hive, he will get a different schema when reading it out. This is undesired.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)