我想在每次运行之前在hive中初始化数据库。
代码是:
command="hive -e \"drop database if exists some_db cascade; create database some_db\"";
eval $command;
执行失败,错误:
FAILED:执行错误,从org.apache.hadoop.hive.ql.exec.DDLTask返回代码1。 MetaException(消息:无法清除java.sql.SQLSyntaxErrorException:表'hive.COMPLETED_COMPACTIONS'不存在
它重新运行,
eval $command;
我也无法解释这样一个事实:当多次调用命令时,它会一直交替失败。
感谢您对Hive中发生的事情以及如何使其在第一次尝试中发挥作用的建议,谢谢。
详细信息:在AWS EMR 5.7上运行的Hive 2.1在HIVE 1.0上没有看到此类行为
完整错误堆栈
FAILED:执行错误,从org.apache.hadoop.hive.ql.exec.DDLTask返回代码1。 MetaException(消息:无法清除java.sql.SQLSyntaxErrorException:表''hive.COMPLETED_COMPACTIONS'在org.mariadb的org.mariadb.jdbc.internal.util.ExceptionMapper.get(ExceptionMapper.java:125)中不存在。 org.mariadb.jdbc.MariaDb上的ord.mariadb.jdbc.MariaDbStatement.executeQueryEpilog(MariaDbStatement.java:259)中的jdbc.internal.util.ExceptionMapper.throwException(ExceptionMapper.java:69)(MariaDbStatement.java:287) at org.mariadb.jdbc.MariaDbStatement.executeUpdate(MariaDbStatement.java:470)at org.mariadb.jdbc.MariaDbStatement.executeUpdate(MariaDbStatement.java:486)at com.jolbox.bonecp.StatementHandle.executeUpdate(StatementHandle.java:497) )org.apache中的org.apache.hadoop.hive.metastore.txn.TxnHandler.cleanupRecords(TxnHandler.java:1721)org.apache.hadoop.hive.metastore.AcidEventListener.onDropDatabase(AcidEventListener.java:51)。 org.apache.hadoop.hive.met上的hadoop.hive.metastore.HiveMetaStore $ HMSHandler.drop_database_core(HiveMetaStore.java:1098) astore.HiveMetaStore $ HMSHandler.drop_database(HiveMetaStore.java:1130)at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)at sun.reflect.DelegatingMethodAccessorImpl.invoke( DelegatingMethodAccessorImpl.java:43)在org.apache.hadoop的org.apache.hadoop.hive.metastore.RetryingHMSHandler.invokeInternal(RetryingHMSHandler.java:140)的java.lang.reflect.Method.invoke(Method.java:498) .hive.metastore.RetryingHMSHandler.invoke(RetryingHMSHandler.java:99)at com.sun.proxy。$ Proxy19.drop_database(Unknown Source)at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore $ Processor $ drop_database.getResult (ThriftHiveMetastore.java:10518)org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore $ Processor $ drop_database.getResult(ThriftHiveMetastore.java:10502)at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:39 )org.apache.hadoop.hive.metastore.TUGIBasedProcessor $ 1.run(TUGIBasedProcess) or.java:110)org.apache.hadoop.hive.metastore.TUGIBasedProcessor $ 1.run(TUGIBasedProcessor.java:106)at java.security.AccessController.doPrivileged(Native Method)at javax.security.auth.Subject.doAs (Subject.java:422)org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1698)org.apache.hadoop.hive.metastore.TUGIBasedProcessor.process(TUGIBasedProcessor.java:118)org。 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)中的java.util.concurrent.ThreadPoolExecutor $ Worker.run(ThreadPoolExecutor。)中的apache.thrift.server.TThreadPoolServer $ WorkerProcess.run(TThreadPoolServer.java:286)。 java:624)at java.lang.Thread.run(Thread.java:748)引起:org.mariadb.jdbc.internal.util.dao.QueryException:org.mariadb中不存在表'hive.COMPLETED_COMPACTIONS' .jdbc.internal.protocol.AbstractQueryProtocol.getResult(AbstractQueryProtocol.java:479)at org.mariadb.jdbc.internal.protocol.AbstractQueryProtocol.result(AbstractQueryProtocol。 java:400)org.mariadb.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:381)org.mariadb.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:337)org.mariadb .jdbc.MariaDbStatement.execute(MariaDbStatement.java:277)... 27更多Blockquote
看起来您的Hive Metastore架构需要升级。您可以使用schematool命令检查架构版本。
示例输出:
Metastore连接URL:jdbc:mysql:// XXXXXXXXXXXXXXX:3306 / hive?createDatabaseIfNotExist = true Metastore连接驱动程序:org.mariadb.jdbc.Driver Metastore连接用户:hive Hive分发版本:2.1.0 Metastore架构版本:2.1.0
如果您的Metastore架构和Hive分发版本不同,请升级架构。
请确保您先备份,以防万一。还要记住,可能会对架构进行更改,从而破坏旧版Hive发行版的功能,因此您可能无法在Hive发行版之间共享matastore。