sparkSql和hive的整合(spark on hive)

一、在Spark的安裝包下的conf下創(chuàng)建一個(gè)文件 hive-site.xml克懊,不需要更新到其他的節(jié)點(diǎn)夏漱,只需要在客戶端有一份hive-site.xml就可以

<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<?xml-stylesheet type="text/xsl" href="configuration.xsl"?>
<configuration>
<property>
        <name>javax.jdo.option.ConnectionURL</name>
        <value>jdbc:mysql://node1:3306/hive?createDatabaseIfNotExist=true</value>
</property>
<property>
        <name>javax.jdo.option.ConnectionDriverName</name>
        <value>com.mysql.jdbc.Driver</value>
</property>
<property>
        <name>javax.jdo.option.ConnectionUserName</name>
        <value>root</value>
</property>
<property>
        <name>javax.jdo.option.ConnectionPassword</name>
        <value>123456</value>
</property>
</configuration>

二、開啟Hive的metaStore服務(wù)

hive --service metastore & #后臺(tái)啟動(dòng)

三歇僧、啟動(dòng)spark-shell時(shí)指定mysql連接驅(qū)動(dòng)位置

/usr/local/spark/bin/spark-shell \
    --master spark://node1:7077 \
    --executor-memory 512m \
    --total-executor-cores 1 \
    --driver-class-path /usr/local/hive/lib/mysql-connector-java-5.1.32-bin.jar

四、

   import org.apache.spark.sql.hive.HiveContext
   val hc = new HiveContext(sc)
   hc.sql("show databases").show

五、整合可能遇到的問題

1诈悍、問題一:
Unable to instantiate org.apache.hadoop.hive.ql.metadata.SessionHiveMetaStoreClient

解決方法:

需要格式化mysql元數(shù)據(jù)庫:
schematool -dbType mysql -initSchema
2祸轮、問題二:
java.sql.SQLException: Column name pattern can not be NULL or empty  

解決方法:

將 $HIVE_HOME/lib 下 的 mysql-connector-java-6.0.3.jar 替換成 mysql-connector-java-5.1.39.jar。
原因分析:mysql-connector-java 6.x 版本 和 5.1.x 版本不兼容 , nullNamePatternMatchesAll 連接屬性的默認(rèn)值在 mysql-connector-java 5.1 和 6.0 之間發(fā)生了改變. 在 5.1 版本中默認(rèn)值是 true, 而 6.0 版本中默認(rèn)值是 false侥钳。

3适袜、問題三:

2019-07-06T10:01:53,737 ERROR [370c0a81-c922-4c61-8315-264c39b372c3 main] metastore.RetryingHMSHandler: MetaException(message:Hive Schema version 3.1.0 does not match metastore's schema version 1.2.0 Metastore is not upgraded or corrupt)
        at org.apache.hadoop.hive.metastore.ObjectStore.checkSchema(ObjectStore.java:9063)
        at org.apache.hadoop.hive.metastore.ObjectStore.verifySchema(ObjectStore.java:9027)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

這是因?yàn)樵趧?chuàng)建SQLContext實(shí)例的時(shí)候,要求spark編譯的Hive版本和HiveMetaStore里面記錄的Hive版本一致
3.1舷夺、解決方法一

我們可以通過$HIVE_CONF/confi/hive-site.xml 配置hive.metastore.schema.verification參數(shù)來取消這種驗(yàn)證苦酱,這個(gè)參數(shù)的默認(rèn)值是true,我們可以取消驗(yàn)證给猾,設(shè)置為false
<property>
    <name>hive.metastore.schema.verification</name>
    <value>false</value>
</property>

3.2疫萤、解決方法2
直接修改存儲(chǔ)hive元數(shù)據(jù)的VERSION表

SELECT * FROM VERSION;
UPDATE VERSION SET SCHEMA_VERSION='3.1.0' WHERE  VER_ID = 1;
image.png
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市敢伸,隨后出現(xiàn)的幾起案子扯饶,更是在濱河造成了極大的恐慌,老刑警劉巖池颈,帶你破解...
    沈念sama閱讀 219,039評(píng)論 6 508
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件尾序,死亡現(xiàn)場(chǎng)離奇詭異,居然都是意外死亡躯砰,警方通過查閱死者的電腦和手機(jī)每币,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,426評(píng)論 3 395
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來琢歇,“玉大人兰怠,你說我怎么就攤上這事±蠲#” “怎么了揭保?”我有些...
    開封第一講書人閱讀 165,417評(píng)論 0 356
  • 文/不壞的土叔 我叫張陵,是天一觀的道長(zhǎng)涌矢。 經(jīng)常有香客問我,道長(zhǎng)快骗,這世上最難降的妖魔是什么娜庇? 我笑而不...
    開封第一講書人閱讀 58,868評(píng)論 1 295
  • 正文 為了忘掉前任,我火速辦了婚禮方篮,結(jié)果婚禮上名秀,老公的妹妹穿的比我還像新娘。我一直安慰自己藕溅,他們只是感情好匕得,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,892評(píng)論 6 392
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著,像睡著了一般汁掠。 火紅的嫁衣襯著肌膚如雪略吨。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 51,692評(píng)論 1 305
  • 那天考阱,我揣著相機(jī)與錄音翠忠,去河邊找鬼。 笑死乞榨,一個(gè)胖子當(dāng)著我的面吹牛秽之,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播吃既,決...
    沈念sama閱讀 40,416評(píng)論 3 419
  • 文/蒼蘭香墨 我猛地睜開眼考榨,長(zhǎng)吁一口氣:“原來是場(chǎng)噩夢(mèng)啊……” “哼!你這毒婦竟也來了鹦倚?” 一聲冷哼從身側(cè)響起河质,我...
    開封第一講書人閱讀 39,326評(píng)論 0 276
  • 序言:老撾萬榮一對(duì)情侶失蹤,失蹤者是張志新(化名)和其女友劉穎申鱼,沒想到半個(gè)月后愤诱,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 45,782評(píng)論 1 316
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡捐友,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,957評(píng)論 3 337
  • 正文 我和宋清朗相戀三年淫半,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片匣砖。...
    茶點(diǎn)故事閱讀 40,102評(píng)論 1 350
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡科吭,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出猴鲫,到底是詐尸還是另有隱情对人,我是刑警寧澤,帶...
    沈念sama閱讀 35,790評(píng)論 5 346
  • 正文 年R本政府宣布拂共,位于F島的核電站牺弄,受9級(jí)特大地震影響,放射性物質(zhì)發(fā)生泄漏宜狐。R本人自食惡果不足惜势告,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,442評(píng)論 3 331
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望抚恒。 院中可真熱鬧咱台,春花似錦、人聲如沸俭驮。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,996評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至遗遵,卻和暖如春萍恕,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背瓮恭。 一陣腳步聲響...
    開封第一講書人閱讀 33,113評(píng)論 1 272
  • 我被黑心中介騙來泰國打工雄坪, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人屯蹦。 一個(gè)月前我還...
    沈念sama閱讀 48,332評(píng)論 3 373
  • 正文 我出身青樓维哈,卻偏偏與公主長(zhǎng)得像,于是被迫代替她去往敵國和親登澜。 傳聞我的和親對(duì)象是個(gè)殘疾皇子阔挠,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,044評(píng)論 2 355

推薦閱讀更多精彩內(nèi)容