图文精华

About云-梭伦科技»专题 › 技术学习(版主发帖区) › 大数据学习 › Hbase › 问题解答› Running Shark Locally 及可能出现的问题
分享

Running Shark Locally 及可能出现的问题

xioaxu790 2014-7-15 09:19:39 发表于 问题解答 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 0 7993
问题导读

1、如何安装配置Shark？
2、安装配置，常见的有哪几种错误，如何解决？




Shark本地安装
1.下载scala 
  1. wget http://www.scala-lang.org/files/archive/scala-2.9.3.tgz
复制代码

最新有2.10.2.tgz文件 
  1. tar xvfz scala-2.9.3.tgz 
复制代码



2.下载shark and hive压缩包 
  1. wget http://spark-project.org/download/shark-0.7.0-hadoop1-bin.tgz (cdh3) 

  2. tar xvfz shark-0.7.0-*-bin.tgz 
复制代码



3. 配置环境变量 
  1. cd shark-0.7.0/conf 

  2. cp shark-env.sh.template shark-env.sh 

  3. vi shark-env.sh 

  4. export HIVE_HOME=/path/to/hive-0.9.0-bin 

  5. export SCALA_HOME=/path/to/scala-2.9.3 
复制代码



4.测试数据 
  1. CREATE TABLE src(key INT, value STRING); 

  2. LOAD DATA LOCAL INPATH '${env:HIVE_HOME}/examples/files/kv1.txt' INTO TABLE src; 

  3. SELECT COUNT(1) FROM src; 

  4. OK 

  5. 500 

  6. Time taken: 2.149 seconds 
复制代码


没有了hive中的mr，速度快了不少 
  1. CREATE TABLE src_cached AS SELECT * FROM SRC; 

  2. SELECT COUNT(1) FROM src_cached; 
复制代码



安装过程中可能出现的问题及解决
1.问题
  1. CREATE TABLE src(key INT, value STRING); 

  2. FAILED: Error in metadata: MetaException(message:Got exception: org.apache.hadoop.ipc.RPC$VersionMismatch Protocol org.apache.hadoop.hdfs.protocol.ClientProtocol version 

  3. 

  4. mismatch. (client = 61, server = 63)) 

  5. FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask 

  6. 

  7. ERROR exec.Task: FAILED: Error in metadata: MetaException(message:Got exception: org.apache.hadoop.ipc.RPC$VersionMismatch Protocol 

  8. 

  9. org.apache.hadoop.hdfs.protocol.ClientProtocol version mismatch. (client = 61, server = 63)) 

  10. org.apache.hadoop.hive.ql.metadata.HiveException: MetaException(message:Got exception: org.apache.hadoop.ipc.RPC$VersionMismatch Protocol 

  11. 

  12. org.apache.hadoop.hdfs.protocol.ClientProtocol version mismatch. (client = 61, server = 63)) 

  13.         at org.apache.hadoop.hive.ql.metadata.Hive.createTable(Hive.java:544) 

  14.         at org.apache.hadoop.hive.ql.exec.DDLTask.createTable(DDLTask.java:3313) 

  15.         at org.apache.hadoop.hive.ql.exec.DDLTask.execute(DDLTask.java:242) 

  16.         at org.apache.hadoop.hive.ql.exec.Task.executeTask(Task.java:134) 

  17.         at org.apache.hadoop.hive.ql.exec.TaskRunner.runSequential(TaskRunner.java:57) 

  18.         at org.apache.hadoop.hive.ql.Driver.launchTask(Driver.java:1312) 

  19.         at org.apache.hadoop.hive.ql.Driver.execute(Driver.java:1104) 

  20.         at org.apache.hadoop.hive.ql.Driver.run(Driver.java:937) 

  21.         at shark.SharkCliDriver.processCmd(SharkCliDriver.scala:288) 

  22.         at org.apache.hadoop.hive.cli.CliDriver.processLine(CliDriver.java:406) 

  23.         at org.apache.hadoop.hive.cli.CliDriver.processLine(CliDriver.java:341) 

  24.         at shark.SharkCliDriver$.main(SharkCliDriver.scala:203) 

  25.         at shark.SharkCliDriver.main(SharkCliDriver.scala)
复制代码

reason：Hadoop版本与SHARK的Hadoop core jar包版本不一致引起的。
解决：将${HADOOP_HOME}/hadoop-core-*.jar copy 到${SHARK_HOME}/lib_managed/jars/org.apache.hadoop/hadoop-core/目录下面，rm原来的hadoop-core-*.jar
重新进入Shark

2.出现java.lang.NoClassDefFoundError 
  1. /app/hadoop/shark/shark-0.7.0/lib_managed/jars/org.apache.hadoop/hadoop-core/ 

  2. java.lang.NoClassDefFoundError: org/apache/hadoop/thirdparty/guava/common/collect/LinkedListMultimap 

  3.         at org.apache.hadoop.hdfs.SocketCache.<init>(SocketCache.java:48) 

  4.         at org.apache.hadoop.hdfs.DFSClient.<init>(DFSClient.java:253) 

  5.         at org.apache.hadoop.hdfs.DFSClient.<init>(DFSClient.java:220) 

  6.         at org.apache.hadoop.hdfs.DistributedFileSystem.initialize(DistributedFileSystem.java:89) 

  7.         at org.apache.hadoop.fs.FileSystem.createFileSystem(FileSystem.java:1611) 

  8.         at org.apache.hadoop.fs.FileSystem.access$300(FileSystem.java:68) 

  9.         at org.apache.hadoop.fs.FileSystem$Cache.getInternal(FileSystem.java:1645) 

  10.         at org.apache.hadoop.fs.FileSystem$Cache.get(FileSystem.java:1627) 

  11.         at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:254) 

  12.         at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:123) 

  13.         at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:238) 

  14.         at org.apache.hadoop.fs.Path.getFileSystem(Path.java:183) 

  15.         at org.apache.hadoop.hive.metastore.Warehouse.getFs(Warehouse.java:104) 

  16.         at org.apache.hadoop.hive.metastore.Warehouse.getDnsPath(Warehouse.java:136) 

  17.         at org.apache.hadoop.hive.metastore.Warehouse.getWhRoot(Warehouse.java:151) 

  18.         at org.apache.hadoop.hive.metastore.HiveMetaStore$HMSHandler.getDefaultDatabasePath(HiveMetaStore.java:475)

  19.         at org.apache.hadoop.hive.metastore.HiveMetaStore$HMSHandler.createDefaultDB_core(HiveMetaStore.java:353)

  20.         at org.apache.hadoop.hive.metastore.HiveMetaStore$HMSHandler.createDefaultDB(HiveMetaStore.java:371) 

  21.         at org.apache.hadoop.hive.metastore.HiveMetaStore$HMSHandler.init(HiveMetaStore.java:278) 

  22.         at org.apache.hadoop.hive.metastore.HiveMetaStore$HMSHandler.<init>(HiveMetaStore.java:248) 

  23.         at org.apache.hadoop.hive.metastore.HiveMetaStoreClient.<init>(HiveMetaStoreClient.java:114) 

  24.         at org.apache.hadoop.hive.ql.metadata.Hive.createMetaStoreClient(Hive.java:2092) 

  25.         at org.apache.hadoop.hive.ql.metadata.Hive.getMSC(Hive.java:2102) 

  26.         at org.apache.hadoop.hive.ql.metadata.Hive.createTable(Hive.java:538) 

  27.         at org.apache.hadoop.hive.ql.exec.DDLTask.createTable(DDLTask.java:3313) 

  28.         at org.apache.hadoop.hive.ql.exec.DDLTask.execute(DDLTask.java:242) 

  29.         at org.apache.hadoop.hive.ql.exec.Task.executeTask(Task.java:134) 

  30.         at org.apache.hadoop.hive.ql.exec.TaskRunner.runSequential(TaskRunner.java:57) 

  31.         at org.apache.hadoop.hive.ql.Driver.launchTask(Driver.java:1312) 

  32.         at org.apache.hadoop.hive.ql.Driver.execute(Driver.java:1104) 

  33.         at org.apache.hadoop.hive.ql.Driver.run(Driver.java:937) 

  34.         at shark.SharkCliDriver.processCmd(SharkCliDriver.scala:288) 

  35.         at org.apache.hadoop.hive.cli.CliDriver.processLine(CliDriver.java:406) 

  36.         at org.apache.hadoop.hive.cli.CliDriver.processLine(CliDriver.java:341) 

  37.         at shark.SharkCliDriver$.main(SharkCliDriver.scala:203) 

  38.         at shark.SharkCliDriver.main(SharkCliDriver.scala) 

  39. Caused by: java.lang.ClassNotFoundException: org.apache.hadoop.thirdparty.guava.common.collect.LinkedListMultimap 

  40.         at java.net.URLClassLoader$1.run(URLClassLoader.java:202) 

  41.         at java.security.AccessController.doPrivileged(Native Method) 

  42.         at java.net.URLClassLoader.findClass(URLClassLoader.java:190) 

  43.         at java.lang.ClassLoader.loadClass(ClassLoader.java:307) 

  44.         at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) 

  45.         at java.lang.ClassLoader.loadClass(ClassLoader.java:248) 

  46.         ... 36 more
复制代码

reason：CDH版本的缺少一个第三方包guava-*.jar
解决：建一个目录${SHARK_HOME}/lib_managed/jars/org.apache.hadoop/thirdparty，拷贝${HADOOP_HOME}/lib/guava-r09-jarjar.jar到这个目录
重新进入Shark


3.show tables出现问题 
  1. Failed with exception java.io.IOException:java.io.IOException: Cannot create an instance of InputFormat class org.apache.hadoop.mapred.TextInputFormat as specified in 
复制代码

reason：缺少hadoop-lzo-*.jar引起的
解决：建一个目录${SHARK_HOME}/lib_managed/jars/org.apache.hadoop/lib, 拷贝${HADOOP_HOME}/lib/hadoop-lzo-*.jar到这个目录
重新进入Shark


4.SELECT count(1) FROM src_cached出现问题 
  1. spark.SparkException: Job failed: ShuffleMapTask(6, 0) failed: ExceptionFailure(java.lang.NoSuchMethodError: sun.misc.Unsafe.copyMemory(Ljava/lang/Object;JLjava/lang/Object;JJ) 

  2. V)at spark.scheduler.DAGScheduler$anonfun$abortStage$1.apply(DAGScheduler.scala:642) 

  3.         at spark.scheduler.DAGScheduler$anonfun$abortStage$1.apply(DAGScheduler.scala:640) 

  4.         at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60) 

  5.         at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) 

  6.         at spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:640) 

  7.         at spark.scheduler.DAGScheduler.handleTaskCompletion(DAGScheduler.scala:601) 

  8.         at spark.scheduler.DAGScheduler.processEvent(DAGScheduler.scala:300) 

  9.         at spark.scheduler.DAGScheduler.spark$scheduler$DAGScheduler$run(DAGScheduler.scala:364) 

  10.         at spark.scheduler.DAGScheduler$anon$1.run(DAGScheduler.scala:107) 

  11. FAILED: Execution Error, return code -101 from shark.execution.SparkTask
复制代码

reason：java1.6版本低，需要安装jdk7.
解决：安装jdk7, JAVA_HOME指向新的JDK7,问题解决 
  1. tar xvfz jdk-7u25-linux-x64.tar.gz -C /usr/java/ 

  2. export JAVA_HOME=/usr/java/jdk1.7.0_25 

  3. export CLASSPATH=/usr/java/jdk1.7.0_25/lib 
复制代码



重新进入Shark 。



关注公众号，获取大数据、人工智能20套、区块链资源5阶段等资源，随时更新，获取最新技术资源
回复

使用道具 举报

自定义广告语

没找到任何评论，期待你打破沉寂

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

发表新帖
xioaxu790

金牌会员

关注

  • 851

    主题

  • 1000

    帖子

  • 108

    粉丝

TA的主题
关闭

推荐上一条 /2 下一条

关于我们· 联系我们· 加入我们· 小黑屋· 合作伙伴   

Copyright © 2001-2024 About云-梭伦科技 Powered by Discuz! X3.4 Licensed Discuz Team.

简书 / Smrz 京ICP备2020039040号 Wxb 简书网举报电话：021-34700000