我使用flink 1.13.1版本,通过sql创建hive表,程序正常运行,表创建成功,但是没有列信息;我的程序如下: 我连接的是hive 2.3.6版本,使用flink-sql-connector-hive-2.3.6依赖包。
package com.meritdata.cloud.flink.test;
import org.apache.flink.table.api.EnvironmentSettings; import org.apache.flink.table.api.TableEnvironment;
public class Test {
public static void main(String[] args) {
EnvironmentSettings bbSettings = EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build();
TableEnvironment tableEnvironment = TableEnvironment.create(bbSettings);
tableEnvironment.executeSql("create catalog myhive with (" + " 'type' = 'hive', " + " 'default-database' = 'default', " + ")");
tableEnvironment.executeSql("use catalog myhive"); tableEnvironment.executeSql("create table if not exists q1 " + "( id string ) " + "with ('is_generic' = 'false')");
/** * hive上表创建成功,没有列, 信息如下 * desc formatted q1; * * col_name data_type comment * * * Table Parameters: * flink.is_generic false * flink.schema.0.data-type VARCHAR(2147483647) * flink.schema.0.name id * transient_lastDdTime 1627279802 * */
}
}*来自志愿者整理的flink邮件归档
1.13不再使用is_generic来标记是不是hive表了 (改成了'connector'='hive') ,文档需要更新一下。不过还是建议DDL操作hive元数据时用hive dialect。*来自志愿者整理的FLINK邮件归档
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。