從一個鎖表問題了解hive鎖機(jī)制

同事遇到一個問題洗鸵,無論從平臺哪里提交Hive SQL,都沒有進(jìn)度仗嗦,沒有日志膘滨。
鑒于之前已有類似反饋,檢查SQL涉及到的表的鎖稀拐,

show locks xxx_table; // hive sql

發(fā)現(xiàn)有若干shared鎖火邓,對表進(jìn)行解鎖操作

unlock table xxx_table; // hive sql

但是重新執(zhí)行sql依然有鎖表現(xiàn)象,sql主干如下(查出分區(qū)表B中某天用戶德撬,且不在歷史表A中存在铲咨,執(zhí)行前已a(bǔ)dd partition)

insert into table  A partition(dt='20190131')
SELECT DISTINCT user_id, date FROM B WHERE dt='20190131'
and a.user_id not in
(select user_id from A);

發(fā)現(xiàn)不僅是無法插入,其中select user_id from A語句也無法執(zhí)行蜓洪,因?yàn)槭菧y試表纤勒,就重建了(事后估計是多個分區(qū)被鎖了,而且有X鎖隆檀,只解鎖表并不能遞歸對各分區(qū)解鎖)摇天。重建后select disctinct...這整段語句會GC memory exceeded粹湃,便改寫成如下框架(窗口函數(shù)去重替換distinct、外連接替換in):

insert overwrite table A partition(dt='20190131')
select tmpa.user_id from 
(
  select tmp.user_id as user_id, tmp.date as date from
  (
  select t.*,  row_number() over(partition by t.user_id order by t.date desc) as rn
   from  (select * from B WHERE dt='20190131' ) t
  ) tmp where tmp.rn=1
) tmpB
left outer join
(
  select user_id from  A
) tmpA
on tmpA.user_id=tmpB.user_id
where tmpA.user_id is null;  // 其實(shí)最好用left semi join

這樣select語句可以跑了闸翅,但是整句sql依然鎖表再芋。

看了一下資料
Hive Lock 那些事兒
官方文檔
https://www.cnblogs.com/barneywill/p/10185577.html

發(fā)現(xiàn)select .. T1 partition P1語句需要T1, T1.P1上的S鎖,那么對整張分區(qū)表的select需要所有分區(qū)的S鎖坚冀。

回到語句济赎,join操作依賴A表的S鎖,但最終要寫入A表的一個新分區(qū)记某,又要加X鎖司训,造成了死鎖。所以需要讓A表待寫入的分區(qū)不加S鎖

insert overwrite table A partition(dt='20190131')
select tmpa.user_id from 
(
  select tmp.user_id as user_id, tmp.date as date from
  (
  select t.*,  row_number() over(partition by t.user_id order by t.date desc) as rn
   from  (select * from B WHERE dt='20190131' ) t
  ) tmp where tmp.rn=1
) tmpB
left outer join
(
  select user_id from  A  where dt!='20190131' // 添加分區(qū)排除條件
) tmpA
on tmpA.user_id=tmpB.user_id
where tmpA.user_id is null;

成功執(zhí)行液南。

另外壳猜,在SQL執(zhí)行前設(shè)置hive參數(shù)set hive.support.concurrency=false; 可強(qiáng)制忽略鎖,但為了數(shù)據(jù)完整性滑凉,不建議常用此操作统扳。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市畅姊,隨后出現(xiàn)的幾起案子咒钟,更是在濱河造成了極大的恐慌,老刑警劉巖若未,帶你破解...
    沈念sama閱讀 218,546評論 6 507
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件朱嘴,死亡現(xiàn)場離奇詭異,居然都是意外死亡粗合,警方通過查閱死者的電腦和手機(jī)萍嬉,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,224評論 3 395
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來隙疚,“玉大人壤追,你說我怎么就攤上這事∩醯” “怎么了大诸?”我有些...
    開封第一講書人閱讀 164,911評論 0 354
  • 文/不壞的土叔 我叫張陵,是天一觀的道長贯卦。 經(jīng)常有香客問我,道長焙贷,這世上最難降的妖魔是什么撵割? 我笑而不...
    開封第一講書人閱讀 58,737評論 1 294
  • 正文 為了忘掉前任,我火速辦了婚禮辙芍,結(jié)果婚禮上啡彬,老公的妹妹穿的比我還像新娘羹与。我一直安慰自己,他們只是感情好庶灿,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,753評論 6 392
  • 文/花漫 我一把揭開白布纵搁。 她就那樣靜靜地躺著,像睡著了一般往踢。 火紅的嫁衣襯著肌膚如雪腾誉。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 51,598評論 1 305
  • 那天峻呕,我揣著相機(jī)與錄音利职,去河邊找鬼。 笑死瘦癌,一個胖子當(dāng)著我的面吹牛猪贪,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播讯私,決...
    沈念sama閱讀 40,338評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼热押,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了斤寇?” 一聲冷哼從身側(cè)響起桶癣,我...
    開封第一講書人閱讀 39,249評論 0 276
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎抡驼,沒想到半個月后鬼廓,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 45,696評論 1 314
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡致盟,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,888評論 3 336
  • 正文 我和宋清朗相戀三年碎税,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片馏锡。...
    茶點(diǎn)故事閱讀 40,013評論 1 348
  • 序言:一個原本活蹦亂跳的男人離奇死亡雷蹂,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出杯道,到底是詐尸還是另有隱情匪煌,我是刑警寧澤,帶...
    沈念sama閱讀 35,731評論 5 346
  • 正文 年R本政府宣布党巾,位于F島的核電站萎庭,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏齿拂。R本人自食惡果不足惜驳规,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,348評論 3 330
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望署海。 院中可真熱鬧吗购,春花似錦医男、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,929評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至踱启,卻和暖如春报账,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背禽捆。 一陣腳步聲響...
    開封第一講書人閱讀 33,048評論 1 270
  • 我被黑心中介騙來泰國打工笙什, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人胚想。 一個月前我還...
    沈念sama閱讀 48,203評論 3 370
  • 正文 我出身青樓琐凭,卻偏偏與公主長得像,于是被迫代替她去往敵國和親浊服。 傳聞我的和親對象是個殘疾皇子统屈,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,960評論 2 355