报错复现如下:

Flink SQL> create database testdb;
[ERROR] Could not execute SQL statement. Reason:
org.apache.hadoop.hive.metastore.api.MetaException: Get request failed : SELECT `A0`.`PARAM_VALUE` FROM `DATABASE_PARAMS` `A0` WHERE `A0`.`DB_ID` = ? AND `A0`.`PARAM_KEY` = ?
 

原因:

更换hive版本后,元数据库没有重新初始化.

解决方案:

mysql>drop database hive

mysql>create database hive character set latin1;

命令行输入:

schematool -dbType mysql -initSchema

Logo

腾讯云面向开发者汇聚海量精品云计算使用和开发经验,营造开放的云计算技术生态圈。

更多推荐