日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

在CDH上用外部Spark2.2.1安装和配置 CarbonData

發布時間:2024/4/17 编程问答 38 豆豆
生活随笔 收集整理的這篇文章主要介紹了 在CDH上用外部Spark2.2.1安装和配置 CarbonData 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
在CDH上用外部Spark2.2.1 (hadoop free版本)standalone 模式安裝和配置 CarbonData 一、cdh中外部spark(standalone模式安裝) 1、把安裝包和配置文件拷貝到其他機器 1.1復制hdfs、hive等配置文件到spark的conf目錄 spark-env.sh文件最后新增的配置 export SPARK_HOME=/opt/cloudera/parcels/spark2.2.1/lib/spark2 export SPARK_DAEMON_CLASSPATH=$SPARK_HOME/jars/*:$SPARK_HOME/carbonlib/* # - 這里的dsd為spark的master主機 export SPARK_MASTER_HOST=dsd export JAVA_HOME=/usr/java/jdk1.8.0_112 export HADOOP_CONF_DIR=/etc/hadoop/conf export YARN_CONF_DIR=/etc/hadoop/conf.cloudera.yarn/ # Passing a Hadoop configuration directory export SPARK_DIST_CLASSPATH=$(hadoop --config /etc/hadoop/conf classpath) -------------------------------------------------------------------------- spark-defaults.conf文件最后新增的配置 spark.driver.extraJavaOptions="-Dcarbon.properties.filepath = /opt/cloudera/parcels/spark2.2.1/lib/spark2/conf/carbon.properties" spark.executor.extraJavaOptions="-Dcarbon.properties.filepath = /opt/cloudera/parcels/spark2.2.1/lib/spark2/conf/carbon.properties" -------------------------------------------------------------------------- 1.2、slaves文件最后新增的配置(把所有的spark節點都加入,包括master) dsf dse dsd dsb ddf -------------------------------------------------------------------------- 1.3、分發安裝包: scp -r /opt/cloudera/parcels/spark2.2.1 root@192.168.101.217:/opt/cloudera/parcels/ 二、編譯需要版本的carbondata 參考: http://www.zhuyongpeng.cn/1557.html 中文文檔 http://carbondata.iteblog.com/installation-guide.html 1、遇到的問題 1.1、編譯carbondata的cdh版本安裝包:直接用官網的apache版本,裝上去啟動不了。 到安裝目錄下去看一下spark的版本 #不要看cloudera manager的包管理上面的版本,那個是錯誤的 1.2、直接在centos上編譯、在window上編譯不知道有沒有區別。2種都試了。都不行,最終發現不是編譯的carbondata有問題。是cdh集成的spark有問題。怎么試都不行。 最終換成原版的spark2.2.1(hadoop free版本的) 2、解決maven倉庫默認不支持cdh 目前maven倉庫中沒有支持cdh的相關依賴。cloudera自己建立了一個相關的倉庫。要想利用maven添加相關依賴,則必須單獨添加cloudera倉庫。 2.1、項目的pom.xml文件里面, 添加倉庫配置 <repositories> <repository> <id>cloudera</id> <url>https://repository.cloudera.com/artifactory/cloudera-repos/</url> </repository> </repositories> 2.2、在國內使用maven中央倉庫一般會有網絡問題,所以大部分人會使用aliyun倉庫或者其他開源的倉庫。 所以需要修改setting.xml (以下配置中 *,!cloudera 表示除了aliyun倉庫還使用cloudera倉庫) <mirror> <id>nexus-aliyun</id> <mirrorOf>*,!cloudera</mirrorOf> <name>Nexus aliyun</name> <url> http://maven.aliyun.com/nexus/content/groups/public </url> </mirror> 2.3、若未設置自動更新maven項目,則需更新maven項目,然后等待下載相關依賴。完成之后便可以使用cdh進行開發啦 3、在centos下編譯 3.1、安裝thrift-0.9.3,此步驟較為繁瑣,需要其他庫的支持。沒有詳細記錄。 yum install automake bison flex g++ git libboost-all-dev libevent-dev libssl-dev libtool make pkg-config 下載thrift-0.9.3 http://archive.apache.org/dist/thrift/0.9.3/thrift-0.9.3.tar.gz tar -xzvf thrift-0.9.3.tar.gz 3.1、安裝mvn tar?zxvf?apache-maven-3.5.3-bin.tar.gz?-C /root/ssss/ vim /etc/profile #添加mvn的配置信息 export M2_HOME=/root/ssss/apache-maven-3.5.3/ export PATH=$PATH:$M2_HOME/bin source /etc/profile mvn -version mvn -Pwindows -Dmaven.test.skip=true -Pspark-2.2 -Dspark.version=2.2.1 clean package 下載了好幾次才完整的下載了所有依賴jar包。 http://repo1.maven.org/maven2/org/apache/spark/spark-streaming_2.11/2.2.0/ 四、spark集成carbondata 1、編譯 CarbonData?工程,并且從?carbondata-parent-1.4.0\assembly\target\scala-2.11路徑獲取 apache-carbondata-1.4.0-bin-spark2.2.0.cloudera2-hadoop2.7.2.jar。 最后將這個 jar 復制到?$SPARK_HOME/carbonlib?文件夾。 注意: 如果?$SPARK_HOME?路徑下不存在 carbonlib 文件夾,請事先創建它。 壓縮 carbonlib 文件夾的內容到tar.gz?文件中,并將這個壓縮文件移到 carbonlib 文件夾下面。 cd /opt/cloudera/parcels/spark2.2.1/lib/spark2/ tar -zcvf carbonlib.tar.gz carbonlib/ mv carbonlib.tar.gz carbonlib/ 2、到carbondata的源碼當中找到carbon.properties配置文件,并拷貝到spark的配置文件目錄 3、將下面的配置添加到?$SPARK_HOME/conf/carbon.properties?文件中: carbon.storelocation=hdfs://nameservice1/ddhome/carbondata carbon.badRecords.location=hdfs://nameservice1/ddhome/carbondata/badRecords 4、在hdfs中建立上面配置的hdfs://nameservice1/ddhome/carbondata目錄。 hadoop fs -mkdir -p /ddhome/carbondata hadoop fs -mkdir -p /ddhome/carbondata_badRecords hadoop fs -mkdir -p /ddhome/carbondata_data 授予訪問目錄的權限,否則文件寫入不了 hadoop fs -chmod -R 777 /ddhome/carbondata hadoop fs -chmod -R 777 /ddhome/carbondata_badRecords hadoop fs -chmod -R 777 /ddhome/carbondata_data 五、啟動:驗證安裝 1、啟動:standalone集群:有效 /opt/cloudera/parcels/spark2.2.1/lib/spark2/sbin/start-all.sh 2、關閉:standalone集群:有效 /opt/cloudera/parcels/spark2.2.1/lib/spark2/sbin/stop-all.sh 3、spark-submit提交普通任務jar進行測試 成功 --supervise(出現錯誤重啟driver)提交作業的端口是6066(restful接口) /opt/cloudera/parcels/spark2.2.1/lib/spark2/bin/spark-submit --class com.ziyun.DpiGet2Hiveparquet --master spark://192.168.101.218:6066 --deploy-mode cluster --supervise /home/usr/sparkjob/zy-just-spark-1.0.0.jar first --conf spark.network.timeout=300 這種用7077端口也可以提交成功 /opt/cloudera/parcels/spark2.2.1/lib/spark2/bin/spark-submit --class com.ziyun.DpiGet2Hiveparquet --master spark://192.168.101.218:7077 --deploy-mode client /root/zy-just-spark-1.0.0.jar first --conf spark.network.timeout=300 4、目前配置standalone模式的spark是否支持hive(spark任務提示一些錯誤:需要給sparksession添加一些配置 .enableHiveSupport() //開啟hive支持 .config("spark.sql.warehouse.dir", "/user/hive/warehouse")) hadoop fs -chmod -R 777 /user/hive/warehouse #給配置的目錄加入權限 /opt/cloudera/parcels/spark2.2.1/lib/spark2/bin/spark-submit --class com.ziyun.MRecKqmj --master spark://192.168.101.217:7077 --deploy-mode client /root/zy-just-spark-1.0.0.jar first --conf spark.network.timeout=300 5、測試普通任務能否寫入hdfs:新spark(standalone) ##按照后面添加了jar之后,可以正常寫入的 /opt/cloudera/parcels/spark2.2.1/lib/spark2/bin/spark-submit --class com.ziyun.MRecKqmjTest --master spark://192.168.101.217:7077 --deploy-mode client /root/zy-just-spark-1.0.0.jar first --conf spark.network.timeout=300 獨立模式提示找不到hive的classes。需要拷貝這2個jar到spark的jars目錄下 6、最后是把cloudera manager上集成的spark2.2.0.cloudera2版本中相關hive和spark的jar復制到新裝的spark的jar目錄。 把mysql的驅動jar也拷貝過去。在hive里面也是有的。 后面又提示缺失thriftserver。最終是解壓了一個spark自帶hadoo2.6(cm版本的hadoop也是基于2.6)版本的jar,把它里面的jar也拷貝到新裝的spark的jars目錄下。 跑普通spark任務就可以了。

轉載于:https://www.cnblogs.com/double-kill/p/9610159.html

總結

以上是生活随笔為你收集整理的在CDH上用外部Spark2.2.1安装和配置 CarbonData的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。