1.修改配置hive-site.xml ? ?hadoop core-site.xml限制---參考Hive記錄-部署Hive環境

2.啟動hadoop?

#sh /usr/app/hadoop/sbin/start-all.sh3.jps查看五大進程是否齊全：NameNode ?DataNode NodeManager ResourceManager SecondaryNameNode
4.啟動hiveserver2服務
#hive --service hiveserver2 #netstat -ant | grep 10000 #監聽

5.beeline連接

#beeline #beeline>!connect jdbc:hive2://192.168.66.66:10000 #輸入用戶名和密碼 ###登錄系統的用戶名root也行，但是要有操作hadoop hive文件夾的權限 #連接成功就可以操作hive數據了

6.Java遠程連接

6.1 所需包（hive-xxx.jar要與服務器上的hive版本一致）

6.2 src下新建log4j.properties

------------------------------------------------------- inceptor.root.logger=INFO,RFA inceptor.log.dir=/usr/app/hive/logs inceptor.log.file=spark.log# Define the root logger to the system property "hadoop.root.logger". log4j.rootLogger=${inceptor.root.logger}# Set everything to be logged to the console log4j.appender.console=org.apache.log4j.ConsoleAppender log4j.appender.console.target=System.err log4j.appender.console.layout=org.apache.log4j.PatternLayout log4j.appender.console.layout.ConversionPattern=%d{yy/MM/dd HH:mm:ss} %p %c: %m%n# output to file log4j.appender.RFA=org.apache.log4j.RollingFileAppender log4j.appender.RFA.File=${inceptor.log.dir}/${inceptor.log.file} # The MaxFileSize can be 512KB log4j.appender.RFA.MaxFileSize=10MB # Keep three backup files. log4j.appender.RFA.MaxBackupIndex=1024 # Pattern to output: date priority [category] - message log4j.appender.RFA.layout=org.apache.log4j.PatternLayout log4j.appender.RFA.layout.ConversionPattern=%d{yy/MM/dd HH:mm:ss} %p %c: %m%n# Ignore messages below warning level from Jetty, because it's a bit verbose log4j.logger.org.eclipse.jetty=WARN6.3 ?ToHive.java

package hive;import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement;public class ToHive {private static String driverName = "org.apache.hive.jdbc.HiveDriver";public boolean run() {try {Class.forName(driverName);Connection con = null;//端口號默認為10000，根據實際情況修改；//用戶名：root，密碼：1(登錄linux系統)con = DriverManager.getConnection("jdbc:hive2://192.168.66.66:10000/siat", "root", "1");Statement stmt = con.createStatement();ResultSet res = null;String sql = "select count(*) 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();System.out.println("error");return false;}}public static void main(String[] args) throws SQLException {ToHive hiveJdbcClient = new ToHive();hiveJdbcClient.run();}}6.4 右鍵執行-提交任務給hadoop進行計算返回結果

轉載于:https://www.cnblogs.com/xinfang520/p/7684613.html

總結

以上是生活随笔為你收集整理的Hive记录-配置远程连接（JAVA/beeline）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。