搜索

小知识|Spark扫描Kerberos hbase环境配置

程序源代码

共 8756字，需浏览 18分钟

 ·

2020-08-22 13:00

点击上方蓝色字体，选择“设为星标”

回复”资源“获取更多资源

大数据技术与架构
点击右侧关注，大数据开发领域最强公众号！

暴走大数据
点击右侧关注，暴走大数据！


集成kerberos后，很多使用服务的程序代码需要改写，例如java通过jdbc链接impala、java扫描hbase表、java的kafka客户端...除了 spark程序以外。
下面介绍下集成kerberos后，要做什么准备才能让spark程序正常跑起来
在实施方案前，假设读者已经基本熟悉以下技术  (不细说)
  • 熟悉spark程序，spark-submit脚本
  • cdh集成kerberos没有问题
  • hbase没问题
  • 这里不提供spark读hbase代码
方案实施

  • cdh集成spark2，安装完成之后能看到这个玩意：

  • spark集成kerberos

  • 重启spark2并部署客户端

  • 添加软链接

[root@node1 spark2]# vi /etc/extra-lib/hbase/classpath.txt/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/jars/htrace-core-3.0.4.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/jars/htrace-core-3.2.0-incubating.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/jars/htrace-core4-4.0.1-incubating.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/jars/commons-pool2-2.4.3.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/jars/jedis-2.9.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/jars/druid-1.1.6.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-annotations-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-annotations-1.2.0-cdh5.11.0-tests.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-client-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-client.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-common-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-common-1.2.0-cdh5.11.0-tests.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-examples-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-examples.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-external-blockcache-1.2.0-cdh5.11.0.jar"/etc/extra-lib/hbase/classpath.txt" 41L, 3584C/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/jars/htrace-core-3.0.4.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/jars/htrace-core-3.2.0-incubating.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/jars/htrace-core4-4.0.1-incubating.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/jars/commons-pool2-2.4.3.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/jars/jedis-2.9.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/jars/druid-1.1.6.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-annotations-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-annotations-1.2.0-cdh5.11.0-tests.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-client-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-client.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-common-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-common-1.2.0-cdh5.11.0-tests.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-examples-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-examples.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-external-blockcache-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-external-blockcache.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-hadoop2-compat-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-hadoop2-compat-1.2.0-cdh5.11.0-tests.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-hadoop-compat-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-hadoop-compat-1.2.0-cdh5.11.0-tests.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-it-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-it-1.2.0-cdh5.11.0-tests.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-prefix-tree-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-procedure-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-protocol-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-resource-bundle-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-rest-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-rsgroup-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-rsgroup-1.2.0-cdh5.11.0-tests.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-server-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-server-1.2.0-cdh5.11.0-tests.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-shell-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-spark-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hbase/hbase-thrift-1.2.0-cdh5.11.0.jar/opt/cloudera/parcels/CDH/jars/ojdbc6.jar/etc/extra-lib/hbase/spring/spring-beans-5.0.2.RELEASE.jar/etc/extra-lib/hbase/spring/spring-core-5.0.2.RELEASE.jar/etc/extra-lib/hbase/spring/spring-expression-5.0.2.RELEASE.jar/etc/extra-lib/hbase/spring/spring-jcl-5.0.2.RELEASE.jar:wq#每个节点都要有scp /etc/extra-lib/hbase/classpath.txt  root@bi-slave1:/etc/extra-lib/hbase/...

修改Spark2在CM内的配置：
“spark2-conf/spark-env.sh 的 Spark 2 服务高级配置代码段（安全阀）”
“spark2-conf/spark-env.sh 的 Spark 2 客户端高级配置代码段（安全阀）”
在以上两个配置框内加入：
export SPARK_DIST_CLASSPATH="SPARKDISTCLASSPATH(paste -sd: "/etc/extra-lib/hbase/classpath.txt")"


  • 重启spark，并部署客户端

  • 添加hbase_site.xml到$SPARK_HOME/conf

  • 下载客户端代码



  • 解压获得hbase_site.xml文件, 并添加到$SPARK_HOME/conf里面


yarn-conf里面也需要有该xml

  • 拷贝到其他节点

spark测试

  • 因为写的spark程序需要读取hbase的表，先给用户赋权限，这里以deng_yb账号为例子

  • 用hbase账号登录hbase shell

[root@node1 ~]# kinit -kt /opt/cm-5.11.0/run/cloudera-scm-agent/process/1247-hbase-HBASERESTSERVER/hbase.keytab hbase/node1@W.COM[root@node1 ~]# klistTicket cache: FILE:/tmp/krb5cc_0Default principal: hbase/node1@W.COM
Valid starting     Expires            Service principal06/13/18 21:20:03  06/14/18 21:20:03  krbtgt/W.COM@W.COM        renew until 06/18/18 21:20:03[root@node1 ~]# hbase shell.....

  • 为deng_yb账号赋权

  • 这里赋权U:DAY_ORG_CMP_OSI和U:DAY_ORG_PRO_CATE_SPARK读写

hbase(main):001:0> listTABLE                                                                                                                           U:DAY_ORG_CMP_OSI                                                                                                     U:DAY_ORG_PRO_CATE_SPARK                                                                                          test                                                                                                                            test_user                                                                                                                       user_info                                                                                                                       5 row(s) in 0.5330 seconds
=> ["U:DAY_ORG_CMP_OSI", "U:DAY_ORG_PRO_CATE_SPARK", "test", "test_user", "user_info"]hbase(main):002:0> grant 'deng_yb','RW','U:DAY_ORG_CMP_OSI'0 row(s) in 0.6180 seconds
hbase(main):003:0> grant 'deng_yb','RW','U:DAY_ORG_PRO_CATE_SPARK'0 row(s) in 0.1320 seconds

  • 登录deng_yb账号

[root@node1 ~]# kinit deng_ybPassword for deng_yb@W.COM: [root@node1 ~]# klistTicket cache: FILE:/tmp/krb5cc_0Default principal: deng_yb@W.COM
Valid starting     Expires            Service principal06/13/18 21:24:18  06/14/18 21:24:18  krbtgt/W.COM@W.COM        renew until 06/20/18 21:24:18

  • 查看hbase权限下的表


hbase(main):001:0> listTABLE                                                                                                                           U:DAY_ORG_CMP_OSI                                                                                                     U:DAY_ORG_PRO_CATE_SPARK                                                                                          2 row(s) in 0.5380 seconds
=> ["U:DAY_ORG_CMP_OSI", "U:DAY_ORG_PRO_CATE_SPARK"]hbase(main):002:0>#赋权成功

  • 执行spark程序 （执行的账号必须能够访问hive元数据）



 spark2-submit --master yarn --deploy-mode cluster  --executor-memory 4G --total-executor-cores 4 --driver-memory 4g --class com.W.Main  /usr/local/W/bi-bdap-0.1.0-SNAPSHOT.jar

  • 执行完之后，记得去查看AM日志


  • AM日志没问题，再去看executors日志


    到这里，假如日志没显示异常代表spark运行成功

问题解惑

  • 部分开发遇到认证失败


这种情况一般是因为$SPARK_CLASSPATH里面没有hbase的包
以下几个jar是必须要有的

  • 连接hbase一直报超时


这种情况下一般是因为$SPARK_HOME/conf下缺少hbase_site.xml文件。

  • 结论

  • spark在集群环境跑，必须要满足
    1).sparkclassath 必须包含hbase相关jar

  • SPARK_HOME/conf必须要有hbase_site.xml或者程序Configuration必须


版权声明：

本文为大数据技术与架构整理，原作者独家授权。未经原作者允许转载追究侵权责任。
编辑｜冷眼丶
微信公众号｜import_bigdata


欢迎点赞+收藏+转发朋友圈素质三连


文章不错？点个【在看】吧！ ?

浏览 30
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报
评论
图片
表情
推荐
Spark读写Hbase（用户画像）
肉眼品世界
0
Spark主入口配置
场 景手写Spark的时候，每个程序的主入口都会用到SparkConf,SparkContext,HiveContext或者SparkSession,那么这三者之间有什么联系呢？  首先,带Context （SparkContext，HiveContext等，后续简称Context）关键字和Sp...
Angular 环境配置
web前端开发
0
WACAWeb应用配置扫描工具
微软WebApplicationConfigurationAnalyzer(WACA)是一款web应用程序配置扫描工具,它可以针对预览版和正式版服务器进行最佳推荐配置扫描。其最佳配置列表是来自微软的信
【建议收藏】HBase配置检查清单
程序源代码
0
SpringBoot 配置 ELK 环境
作者：JingQhttps://www.sevenyuan.cn/在看大型网站的中间件技术，对于Elasticsearch有点兴趣，所以将配置流程记录了一下为什么要用ELKELK实际上是三个工具，Elastricsearch + LogStash + Kibana，通过ELK，用来收集...
Docker环境配置指南！
Datawhale
0
SpringBoot 配置 ELK 环境
Java技术江湖
0
SLAM基础环境配置
新机器视觉
0
Docker环境配置指南
机器学习实验室
0
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报