jdbc-hiveserver：“client_protocol is unset！”-都是CS中的1.1.1

Question

当我问这个问题的时候，我已经通过谷歌读了很多很多文章。很多答案都表明这是客户端和服务器端的版本不匹配。所以我决定直接将JAR从服务器端复制到客户端，结果是....如您所知，同样例外情况：

org.apache.thrift.TApplicationException: Required field 'client_protocol' is unset! Struct:TOpenSessionReq(client_protocol:null, configuration:{use:database=default})

当我通过beeline连接到hiveserver2时就会很顺利：）查看我的连接。

所以，我想当我使用jdbc时，它也会起作用。但是，不幸的是，它抛出了一个异常，下面是我项目中的JAR。

null

    def connect_hive(master:String){
        val conf = new SparkConf()
                        .setMaster(master)
                        .setAppName("Hive")
                        .set("spark.local.dir", "./tmp");
        val sc = new SparkContext(conf);
        val sqlContext = new SQLContext(sc);
        val url = "jdbc:hive2://192.168.40.138:10000";
        val prop= new Properties();
        prop.setProperty("user", "hive");
        prop.setProperty("password", "hive");
        prop.setProperty("driver", "org.apache.hive.jdbc.HiveDriver");
        val conn = DriverManager.getConnection(url, prop);
        sc.stop();
      }

• Hadoop 2.7.3
• 火花1.6.0
• 配置单元1.1.1

有人在通过Spark-JDBC连接hive时遇到同样的情况吗？

Answer 1

由于beeline可以工作，预计您的程序也应该正确执行。

你可以尝试一些像这样的事情来了解你的自我。

import java.net.URL
import java.net.URLClassLoader

import scala.collection.JavaConversions._

object App {

  def main(args: Array[String]) {
    val cl = ClassLoader.getSystemClassLoader
    val urls = cl.asInstanceOf[URLClassLoader].getURLs
    for (url <- urls) {
      println(url.getFile)
    }
  }
}

还要检查hive.aux.jars.path= 以了解类路径中存在哪些JAR。