[
https://issues.apache.org/jira/browse/FLINK-29152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-29152.
---------------------------
Fix Version/s: 1.16.0
1.17.0
Assignee: luoyuxia
Resolution: Fixed
Fixed in
- master: b5cd9f34ab73fa69a3db5a09908c1aa954ed0597
- release-1.16: a6e954ca3bff9c62713d475627b49dd18a4f02fd
> Describe statement resutls is different from the Hive
> ------------------------------------------------------
>
> Key: FLINK-29152
> URL: https://issues.apache.org/jira/browse/FLINK-29152
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Hive
> Affects Versions: 1.16.0
> Reporter: Shengkai Fang
> Assignee: luoyuxia
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.16.0, 1.17.0
>
>
> In hive, the results schema is
> {code:java}
> +-----------+------------+----------+
> | col_name | data_type | comment |
> +-----------+------------+----------+
> | a | int | |
> | b | string | |
> +-----------+------------+----------+
> {code}
> but our implementation is
> {code:java}
> 0: jdbc:hive2://localhost:10000/default> describe sink;
> +-------+-------+-------+-------+---------+------------+
> | name | type | null | key | extras | watermark |
> +-------+-------+-------+-------+---------+------------+
> | a | INT | true | NULL | NULL | NULL |
> +-------+-------+-------+-------+---------+------------+
> {code}
> BTW, it's better we can support {{DESCRIBE FORMATTED}} like hive does.
> {code:java}
> +-------------------------------+----------------------------------------------------+-----------------------+
> | col_name | data_type
> | comment |
> +-------------------------------+----------------------------------------------------+-----------------------+
> | # col_name | data_type
> | comment |
> | | NULL
> | NULL |
> | a | int
> | |
> | b | string
> | |
> | | NULL
> | NULL |
> | # Detailed Table Information | NULL
> | NULL |
> | Database: | default
> | NULL |
> | Owner: | null
> | NULL |
> | CreateTime: | Tue Aug 30 06:54:00 UTC 2022
> | NULL |
> | LastAccessTime: | UNKNOWN
> | NULL |
> | Retention: | 0
> | NULL |
> | Location: |
> hdfs://namenode:8020/user/hive/warehouse/sink | NULL |
> | Table Type: | MANAGED_TABLE
> | NULL |
> | Table Parameters: | NULL
> | NULL |
> | | comment
> | |
> | | numFiles
> | 0 |
> | | totalSize
> | 0 |
> | | transient_lastDdlTime
> | 1661842440 |
> | | NULL
> | NULL |
> | # Storage Information | NULL
> | NULL |
> | SerDe Library: |
> org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe | NULL |
> | InputFormat: | org.apache.hadoop.mapred.TextInputFormat
> | NULL |
> | OutputFormat: |
> org.apache.hadoop.hive.ql.io.IgnoreKeyTextOutputFormat | NULL
> |
> | Compressed: | No
> | NULL |
> | Num Buckets: | -1
> | NULL |
> | Bucket Columns: | []
> | NULL |
> | Sort Columns: | []
> | NULL |
> | Storage Desc Params: | NULL
> | NULL |
> | | serialization.format
> | 1 |
> +-------------------------------+----------------------------------------------------+-----------------------+
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
