Spark¼¯Èº´î½¨Óë²âÊÔ - ͼÎÄ

×¢£º4040¶Ë¿ÚÓÃÀ´²é¿´ÕýÔÚÔËÐеijÌÐòµÄjobÐÅÏ¢£¬¶ø18080ÓÃÀ´²é¿´Ö´ÐÐÍê±ÏµÄ³ÌÐòµÄjobÐÅÏ¢¡£

17. ͨ¹ýspark-submitÌá½»³ÌÐòµ½spark¼¯Èº²âÊÔSPARK¼¯Èº:

a. ͨ¹ýÒÔÏÂÃüÁîÌá½»spark×Ô´øµÄsparkPi³ÌÐò£ºspark-submit --class

org.apache.spark.examples.SparkPi --master spark://master:7077 $SPARK_HOME/lib/spark-examples-1.6.0-hadoop2.6.0.jar

b. webUI²é¿´£º

×¢Ò⣺spark-submit¸üÏêϸµÄÐÅÏ¢Çë²Î¿¼¹Ù·½Îĵµ£º

http://spark.apache.org/docs/latest/submitting-applications.html

18. ¸½Â¼£º³£¼û´íÎóÓë½â¾ö·½·¨£º

a. ´íÎ󣺰²×°ubuntuʱ³öÏÖ´íÎó:This kernel requires an X86-64 CPU, but only

detected an i686 CPU´íÎó¡£½â¾ö·½·¨£º°²×°64λµÄϵͳÐèÒª64λµÄcpuÇÒcpuÒªÔÊÐíÓ²¼þÐéÄ⻯¡£Ê×ÏȲ鿴cpuÊÇ·ñÊÇ64 룬ÊǵĻ°È¥biosÀï, ÔÚcpu configurationÖÐÕÒµ½Virtualization£¬½«Æä״̬¸ÄΪenabled.

b. ´íÎó£ºE212:can't open file for writing¡£½â¾ö·½·¨£ºÈ¨ÏÞ²»¹»£¬Çл»µ½ROOT. c. ´íÎó£ºsudoʱ±¨´í: unable to change to root gid: Operation not permitted½â

¾ö·½·¨£ºÕâÊÇÒòΪÎÒÃÇʹÓÃguest½ÇÉ«µÇ¼ϵͳÁË£¬Çл»Óû§£¬Ê¹ÓÃÆÕͨÓû§µÇ¼ϵͳºó¼´¿ÉʹÓÃsudoÃüÁî¡£ d. ´íÎó£ºÖ´ÐÐÏÂÃæÃüÁîÊDZ¨´í£º

root@worker1:~# scp id_rsa.pub root@master:/root/.ssh/id_rsa.pub.slave1 root@worker1's password: Permission denied, please try again.

root@worker1's password: Permission denied, please try again. root@worker1's password: Permission denied (publickey,password).lost connection

½â¾ö·½·¨£ºµÇ¼µ½scpµÄÄ¿±ê»ú£¬½«/etc/ssh/sshd_config ÖÐ×¢Ê͵ô

#PermitRootLogin without-password£¬Ìí¼Ó PermitRootLogin yes,ÖØÆôssh·þÎñ¼´¿É¡££¨sudo service ssh restart.£© e. ´íÎó:Æô¶¯spark history serverʱ±¨´í£º

Exception in thread \

at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstruct orAccessorImpl.java:62) at

sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingC

onstructorAccessorImpl.java:45)atjava.lang.reflect.Constructor.newInstance(Constructor.java:422)

at org.apache.spark.deploy.history.HistoryServer$.main(HistoryServer.sca la:235)at

org.apache.spark.deploy.history.HistoryServer.main(HistoryServer.scal a)Caused by: java.lang.IllegalArgumentException: Log directory specified does not exist: file:/tmp/spark-events. Did you configure the correct one through spark.history.fs.logDirectory?

½â¾ö·½·¨:ÔÚÆô¶¯spark history serverʱÐèÒªÔÚÃüÁîÐж¯Ì¬Ö¸¶¨Ä¿Â¼,»òÌáǰÅäÖúÃÏà¹Ø²ÎÊý¡£ÒÔspark.history¿ªÍ·µÄÐèÒªÅäÖÃÔÚspark-env.shÖеÄ

SPARK_HISTORY_OPTS£¬ÒÔspark.eventLog¿ªÍ·µÄÅäÖÃÔÚspark-defaults.conf¡£ ¿ÉÒÔÔÚspark-defaults.confÖÐÌí¼ÓÈçÏÂÅäÖ㺠spark.eventLog.enabled true

spark.eventLog.dir hdfs://spark/jobhistory spark.history.fs.logDirectory hdfs://spark/jobhistory

ÁªÏµ¿Í·þ£º779662525#qq.com(#Ìæ»»Îª@)