hiveserver2的配置和使用 hive-site.xml配置 hiveserver2的配置 property name hive.support.concurrency / name description Enable Hive's TableLock Manager Service / description value true / value / property property name hive.zookeeper.quorum /
hiveserver2的配置和使用
hive-site.xml配置
hiveserver2的配置
property>
name>hive.support.concurrencyname>
description>Enable Hive's TableLock Manager Servicedescription>
value>truevalue>
property>
property>
name>hive.zookeeper.quorumname>
description>
Zookeeper quorum used by Hive's Table Lock Manager
description>
value>
e3basestorage1:2181,e3basestorage2:2181,e3basestorage3:2181
value>
property>
property>
name>hive.server2.thrift.bind.hostname>
value>172.21.3.170value>
description>
Bind host on which to run the HiveServer2 Thrift interface.Can
be overridden by setting $HIVE_SERVER2_THRIFT_BIND_HOST
description>
property>
远程访问元数据的配置
property>
name>hive.metastore.urisname>
value>thrift://172.21.1.56:9083value>
description>Thrift uri for the remote metastore. Used by metastoreclient to connect to remote metastore.description>
property>
property>
name>hive.metastore.localname>
value>falsevalue>
description>this is local store .description>
property>
shell交互
bin/beeline
!connectjdbc:hive2://localhost:10000 e3base e3base123 org.apache.hive.jdbc.HiveDriver (红字为当前的用户名和密码
)
Jdbc连接
远程启动元数据服务：
nohup bin/hive --servicemetastore&
启动hiveserver2服务
nohup bin/hive --servicehiveserver2 & 以后台进程的方式启动
Java客户端访问
示例代码：
package com.sitech;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import org.apache.log4j.Logger;
public class T1 {
private static Logger log = Logger.getLogger(T1.class);
private static String driverName = "org.apache.hive.jdbc.HiveDriver";
public boolean run() {
try {
Class.forName(driverName);
Connection con = null;
con = DriverManager.getConnection(
"jdbc:hive2://172.21.3.170:10000/hivedb", "", "");
Statement stmt = con.createStatement();
ResultSet res = null;
String sql = "selectcount(*) from test";
System.out.println("Running:" + sql);
res = stmt.executeQuery(sql);
System.out.println("ok");
while (res.next()) {
System.out.println(res.getString(1));
}
return true;
} catch (Exception e) {
e.printStackTrace();
log.error("Connection:" + e.getMessage());
System.out.println("error");
return false;
}
}
public static void main(String[] args) throws SQLException {
HiveJdbcClienthiveJdbcClient = new HiveJdbcClient();
hiveJdbcClient.run();
}
}
