最近在部署Hive上線(xiàn)，結(jié)果在線(xiàn)上線(xiàn)下同時(shí)出現(xiàn)了MoveTask報(bào)錯(cuò)的現(xiàn)象，雖然兩者錯(cuò)誤的日志以及錯(cuò)誤信息一樣，但是經(jīng)過(guò)分析解決又發(fā)現(xiàn)兩者的原因是不一樣的。
首先線(xiàn)下的錯(cuò)誤日志：
2015-05-18 18:53:09,679 ERROR [main]: exec.Task (SessionState.java:printError(833)) - Failed with exception Unable to rename: hdfs:
//
hadoop-master:9000/tmp/hive/hadoop/4d905c9f-ee65-4b1f-be96-93115b3aad61/hive_2015-05-18_18-51-42_401_2711668916550397051-1/-ext-10000 to: /user/hive/partitions/users_statis/dt_user_statis_behavior/event=play/period=0
org.apache.hadoop.hive.ql.metadata.HiveException: Unable to rename: hdfs:
//
hadoop-master:9000/tmp/hive/hadoop/4d905c9f-ee65-4b1f-be96-93115b3aad61/hive_2015-05-18_18-51-42_401_2711668916550397051-1/-ext-10000 to: /user/hive/partitions/users_statis/dt_user_statis_behavior/event=play/period=0
at org.apache.hadoop.hive.ql.exec.MoveTask.moveFile(MoveTask.java:111
)
at org.apache.hadoop.hive.ql.exec.MoveTask.execute(MoveTask.java:
213
)
at org.apache.hadoop.hive.ql.exec.Task.executeTask(Task.java:
160
)
at org.apache.hadoop.hive.ql.exec.TaskRunner.runSequential(TaskRunner.java:
85
)
at org.apache.hadoop.hive.ql.Driver.launchTask(Driver.java:
1604
)
at org.apache.hadoop.hive.ql.Driver.execute(Driver.java:
1364
)
at org.apache.hadoop.hive.ql.Driver.runInternal(Driver.java:
1177
)
at org.apache.hadoop.hive.ql.Driver.run(Driver.java:
1004
)
at org.apache.hadoop.hive.ql.Driver.run(Driver.java:
994
)
at org.apache.hadoop.hive.cli.CliDriver.processLocalCmd(CliDriver.java:
247
)
at org.apache.hadoop.hive.cli.CliDriver.processCmd(CliDriver.java:
199
)
at org.apache.hadoop.hive.cli.CliDriver.processLine(CliDriver.java:
410
)
at org.apache.hadoop.hive.cli.CliDriver.executeDriver(CliDriver.java:
783
)
at org.apache.hadoop.hive.cli.CliDriver.run(CliDriver.java:
677
)
at org.apache.hadoop.hive.cli.CliDriver.main(CliDriver.java:
616
)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:
57
)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:
43
)
at java.lang.reflect.Method.invoke(Method.java:
606
)
at org.apache.hadoop.util.RunJar.run(RunJar.java:
221
)
at org.apache.hadoop.util.RunJar.main(RunJar.java:
136)
這個(gè)問(wèn)題在http://blog.csdn.net/lucien_zong/article/details/10198533中有詳細(xì)的描述
執(zhí)行SQL時(shí)，最后一個(gè)任務(wù)是MoveTask,它的作用是將運(yùn)行SQL生成的Mapeduce任務(wù)結(jié)果文件放到SQL中指定的存儲(chǔ)查詢(xún)結(jié)果的路徑中，具體方法就是重命名
下面是 org.apache.hadoop.hive.ql.exec.MoveTask 中對(duì)結(jié)果文件重命名的一段代碼：//這個(gè)sourcePath參數(shù)就是存放Mapeduce結(jié)果文件的目錄，所以它的值可能是 //hdfs://indigo:8020/tmp/hive-root/hive_2013-08-22_18-42-03_218_2856924886757165243/-ext-10000 if (fs.exists(sourcePath)) { Path deletePath = null ; // If it multiple level of folder are there fs.rename is failing so first // create the targetpath.getParent() if it not exist if (HiveConf.getBoolVar(conf, HiveConf.ConfVars.HIVE_INSERT_INTO_MULTILEVEL_DIRS)) { deletePath = createTargetPath(targetPath, fs); } //這里targetPath的值就是指定的放置結(jié)果文件的目錄，值可能是 result/userName154122639/4e574b5d9f894a70b074ccd3981ca0f1 if (!fs.rename(sourcePath, targetPath)) {//上面產(chǎn)生的異常就是因?yàn)檫@里rename失敗，進(jìn)了if，throw了個(gè)異常 try { if (deletePath != null ) { fs.delete(deletePath, true ); } } catch (IOException e) { LOG.info("Unable to delete the path created for facilitating rename" + deletePath); } throw new HiveException("Unable to rename: " + sourcePath + " to: " + targetPath); } }rename的targetPath必須存在。
其實(shí)之前已經(jīng)檢查和創(chuàng)建targetPath了：
?
private Path createTargetPath(Path targetPath, FileSystem fs) throws IOException { Path deletePath = null ; Path mkDirPath = targetPath.getParent(); if (mkDirPath != null & ! fs.exists(mkDirPath)) { Path actualPath = mkDirPath; while (actualPath != null && ! fs.exists(actualPath)) { deletePath = actualPath; actualPath = actualPath.getParent(); }? <property> <name>hive.insert.into.multilevel.dirs</name> <value>true</value> </property>? fs.mkdirs(mkDirPath); } return deletePath;//返回新創(chuàng)建的最頂層的目錄，萬(wàn)一失敗用來(lái)刪除用 }Apache出現(xiàn)過(guò)這個(gè) 問(wèn)題 ，已經(jīng)解決掉了
CDH 竟然加了個(gè)參數(shù) hive.insert.into.multilevel.dirs，默認(rèn)是false，意思是我還有這BUG呢哈。
當(dāng)你被坑了，想打個(gè)patch時(shí)，會(huì)發(fā)現(xiàn)改個(gè)配置就可以了。
意思是我保留這個(gè)BUG，但你要是被坑了也不能說(shuō)我有BUG，自己改配置好了.
目前還沒(méi)發(fā)現(xiàn)其他地方用到了這個(gè)參數(shù)，在這里唯一作用就是限制SQL中指定存放結(jié)果文件不存在的目錄的深度不能大于1.
不過(guò)也沒(méi)發(fā)現(xiàn)這有什么好處。折騰半天，加個(gè)配置就可以了:
? <property> <name>hive.insert.into.multilevel.dirs</name> <value> true </value> </property> ?
解決完線(xiàn)下的問(wèn)題滿(mǎn)心歡喜的以為可以解決線(xiàn)上的問(wèn)題，結(jié)果發(fā)現(xiàn)了不行，仔細(xì)查看日志發(fā)現(xiàn)原來(lái)是因?yàn)槿卑斐傻?
2015-05-18 19:22:03,799 ERROR [main]: exec.Task (SessionState.java:printError(861)) - Failed with exception Unable to move source hdfs:
//
hadoop1:9000/tmp/hive/statistics/dt_statistics_content_daily/.hive-staging_hive_2015-05-18_19-11-45_323_132664610162390564-1/-ext-10000 to destination /tmp/hive/statistics/dt_statistics_content_daily
org.apache.hadoop.hive.ql.metadata.HiveException: Unable to move source hdfs:
//
hadoop1:9000/tmp/hive/statistics/dt_statistics_content_daily/.hive-staging_hive_2015-05-18_19-11-45_323_132664610162390564-1/-ext-10000 to destination /tmp/hive/statistics/dt_statistics_content_daily
at org.apache.hadoop.hive.ql.metadata.Hive.moveFile(Hive.java:2483
)
at org.apache.hadoop.hive.ql.exec.MoveTask.moveFile(MoveTask.java:
105
)
at org.apache.hadoop.hive.ql.exec.MoveTask.execute(MoveTask.java:
222
)
at org.apache.hadoop.hive.ql.exec.Task.executeTask(Task.java:
160
)
at org.apache.hadoop.hive.ql.exec.TaskRunner.runSequential(TaskRunner.java:
88
)
at org.apache.hadoop.hive.ql.Driver.launchTask(Driver.java:
1638
)
at org.apache.hadoop.hive.ql.Driver.execute(Driver.java:
1397
)
at org.apache.hadoop.hive.ql.Driver.runInternal(Driver.java:
1183
)
at org.apache.hadoop.hive.ql.Driver.run(Driver.java:
1049
)
at org.apache.hadoop.hive.ql.Driver.run(Driver.java:
1039
)
at org.apache.hadoop.hive.cli.CliDriver.processLocalCmd(CliDriver.java:
207
)
at org.apache.hadoop.hive.cli.CliDriver.processCmd(CliDriver.java:
159
)
at org.apache.hadoop.hive.cli.CliDriver.processLine(CliDriver.java:
370
)
at org.apache.hadoop.hive.cli.CliDriver.executeDriver(CliDriver.java:
754
)
at org.apache.hadoop.hive.cli.CliDriver.run(CliDriver.java:
675
)
at org.apache.hadoop.hive.cli.CliDriver.main(CliDriver.java:
615
)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:
57
)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:
43
)
at java.lang.reflect.Method.invoke(Method.java:
606
)
at org.apache.hadoop.util.RunJar.run(RunJar.java:
221
)
at org.apache.hadoop.util.RunJar.main(RunJar.java:
136
)
Caused by: java.io.IOException: Cannot find DistCp
class
package
: org.apache.hadoop.tools.DistCp
at org.apache.hadoop.hive.shims.Hadoop23Shims.runDistCp(Hadoop23Shims.java:
1123
)
at org.apache.hadoop.hive.common.FileUtils.copy(FileUtils.java:
553
)
at org.apache.hadoop.hive.ql.metadata.Hive.moveFile(Hive.java:
2461
)
...
21 more
查看源碼發(fā)現(xiàn)在調(diào)用moveFile時(shí)候會(huì)去調(diào)用Hadoop的distcp接口
@Override
public
boolean
runDistCp(Path src, Path dst, Configuration conf)
throws
IOException {
int
rc;
//
Creates the command-line parameters for distcp
String[] params = {"-update", "-skipcrccheck"
, src.toString(), dst.toString()};
try
{
Class clazzDistCp
= Class.forName("org.apache.hadoop.tools.DistCp"
);
Constructor c
=
clazzDistCp.getConstructor();
c.setAccessible(
true
);
Tool distcp
=
(Tool)c.newInstance();
distcp.setConf(conf);
rc
=
distcp.run(params);
}
catch
(ClassNotFoundException e) {
throw
new
IOException("Cannot find DistCp class package: " +
e.getMessage());
}
catch
(NoSuchMethodException e) {
throw
new
IOException("Cannot get DistCp constructor: " +
e.getMessage());
}
catch
(Exception e) {
throw
new
IOException("Cannot execute DistCp process: " +
e, e);
}
return
(0 ==
rc);
}
使用命令發(fā)現(xiàn)Hive環(huán)境變量中并沒(méi)有Hadoop-Distcp-2.6.0.jar
? hive -e 'set' | grep distcp ?
于是只要把hadoop/share/tools/下的Hadoop-Distcp-2.6.0.jar加載下來(lái)就行。
需要說(shuō)明的是線(xiàn)上的Hive是1.1.0版本，線(xiàn)下的hive是0.14版本。同時(shí)需要注意的是線(xiàn)下的move文件的方式是rename，線(xiàn)上則用distcp方式，這跟Hive的版本有關(guān)了。
?
更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號(hào)聯(lián)系： 360901061
您的支持是博主寫(xiě)作最大的動(dòng)力，如果您喜歡我的文章，感覺(jué)我的文章對(duì)您有幫助，請(qǐng)用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點(diǎn)擊下面給點(diǎn)支持吧，站長(zhǎng)非常感激您！手機(jī)微信長(zhǎng)按不能支付解決辦法：請(qǐng)將微信支付二維碼保存到相冊(cè)，切換到微信，然后點(diǎn)擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對(duì)您有幫助就好】元
