如何从Hive Metastore获取Flink创建表ddl

Question

我有几张Flink表，它们都存放在Metastore蜂巢里。我想收回所有这些表，然后生成create 。

这里有一个演示来描述我想要的。

例如，我有一个Flink表，如

CREATE TABLE if not exists cdc_log (log STRING) 
WITH (
        'connector' = 'kafka',  
        'topic-pattern' = 'xxx',  
        'properties.bootstrap.servers' = 'xxx',  
        'properties.group.id' = 'xxx',  
        'scan.startup.mode' = 'xxx',  
        'format' = 'raw');

Hive执行，显示创建表cdc_log，我们得到在Flink运行时无法执行的DDL。

CREATE TABLE `cdc_log`(
)
ROW FORMAT SERDE 
  'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe' 
STORED AS INPUTFORMAT 
  'org.apache.hadoop.mapred.TextInputFormat' 
OUTPUTFORMAT 
  'org.apache.hadoop.hive.ql.io.IgnoreKeyTextOutputFormat'
LOCATION
  'hdfs://xxx'
TBLPROPERTIES (
  'flink.connector'='kafka', 
  'flink.format'='raw', 
  'flink.properties.bootstrap.servers'='xxx', 
  'flink.properties.group.id'='xxx', 
  'flink.scan.startup.mode'='earliest-offset', 
  'flink.schema.0.data-type'='VARCHAR(2147483647)', 
  'flink.schema.0.name'='log', 
  'flink.topic-pattern'='xxx', 
  'transient_lastDdlTime'='1645607171')

而Flink 则描述没有信息的cdc_log返回。我找不到拿回我的DDL的方法。有办法解决这个问题吗？谢谢。

Answer 1

哈哈..。我想我可以用CatalogBaseTable.getOptions()来解决它..。