[ 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)