程序员的自我修养
Home » Apache Spark » Spark集群问题小结

Spark集群问题小结

0条评论1,806次浏览

JAVA版本问题

master进程以jdk7运行,worker以jdk6运行。

产生原因

集群中的机器曾由jdk6升级至jdk7,升级后未卸载jdk6。由未知原因(初步推测ssh配置的问题),导致ssh host "java -version"命令结果显示为jdk6,但ssh至host后再运行java -version命令则显示jdk7。而spark运行worker是通过ssh来启动的,所以导致worker全部以jdk6启动。

解决方法

在spark执行用户下的.bashrc中加入$JAVA_HOME, $PATH等环境变量,然后重启集群。

pid文件问题

运行$SPARK_HOME/sbin/下的各种stop开头的sh文件都会显示类似下方错误:

产生原因

spark默认将master和worker的pid文件放在/tmp目录下,linux系统默认每30天清理一次/tmp目录下的文件。pid文件丢失将导致无法正确关闭相应进程。

解决方法

修改集群所有$SPARK_HOME/conf/spark-env.sh文件,加入环境变量SPARK_PID_DIR:

对于已丢失pid文件的spark集群,可在$SPARK_PID_DIR目录下手动创建pid文件并写入正确的pid,然后运行$SPARK_HOME/sbin/stop-all.sh即可关闭集群;或者手动kill master和worker进程。

master pid文件名:spark-push-org.apache.spark.deploy.master.Master-1.pid (可参考logs下面的日志名称)

worker pid文件名:spark-push-org.apache.spark.deploy.worker.Worker-1.pid (可参考logs下面的日志名称)

写hbase问题

spark任务无法写hbase,报错如下:

产生原因

hbase bug导致,详见jira:https://issues.apache.org/jira/browse/HBASE-10304

解决方法1

集群所有$SPARK_HOME/conf/spark-defaults.conf文件中添加:

并将hbase-protocol-0.98.1-cdh5.1.0.jar文件分发到集群中每台机器相应的路径下($SOME_PATH),然后重启集群。

解决方法2

集群不方便重启的情况下,可通过修改提交作业命令来解决:

同样需要将hbase-protocol-0.98.1-cdh5.1.0.jar文件分发到集群中每台机器相应的路径下。

(转载本站文章请注明作者和出处 程序员的自我修养 – SelfUp.cn ,请勿用于任何商业用途)
分类:Apache Spark
标签:
发表评论


profile
  • 文章总数:79篇
  • 评论总数:339条
  • 分类总数:31个
  • 标签总数:44个
  • 运行时间:978天

大家好,欢迎来到selfup.cn。

这不是一个只谈技术的博客,这里记录我成长的点点滴滴,coding、riding and everthing!

最新评论
  • yurnom: 可能苹果最近又改变了返回值吧,最近没做测试了。 BadDeviceToken一般测试环境和正式环境弄错的情况 下会出现。
  • Anonymous: :razz: 博主,良心贴啊, 最近也在弄apns推送。 有个问题想请教你一下啊。 你博客中写的 Unregistered 错误,有准确的说明吗, 我看你博客中写的:...
  • 一波清泉: 回复邮箱: 1004161699@qq.com 多谢
  • Anonymous: 17/02/09 01:15:02 WARN Utils: Service ‘SparkUI’ could not bind on port 4040. Attempting port...
  • pacificLee: :twisted:
  • 小码: 为什么没有后面的呢,只有前10个
  • Anonymous: :lol:
  • Anonymous: :razz: 楼主是属于会聊天的。 我想问,sqoop发了几个版本了,应该没这些问题了吧。
  • Anonymous: Config.kafkaConfig.kafkaGroupI d 这个是指自己配置的group id 还是从 import org.apache.kafka.common.config .Config 这个类...
  • Anonymous: ZkUtils.getPartitionsForTopics (zkClient, Config.kafkaConfig.topic) 那个方法是在 spark-streaming_2.10 中 kafka...
  • Anonymous: ZkUtils.getPartitionsForTopics (zkClient, Config.kafkaConfig.topic) 你确定 kafka 里面有这个类 ? 个人在kafka 最新 稳定版...
  • Anonymous: :roll:
  • Anonymous: 很不错,试问有java版的吗?
  • Anonymous: 赞
  • Anonymous: 哈哈 看楼主的吐槽乐死了 where子句是可以写的 同样找不到资料 一点点试出来的 select id from xxxx where ${CONDITIONS} and 1=1 and 2=2 limit 4
  • EVIL: 我在运行完C4.5的代码后,显示 defined object DecisionTreeTest 是什么意思?这是有错误吗?运行结果在哪里看?
  • sf: 楼主的问题,我都遇到。。。没办法项目已经定型了,最后都硬着头 皮一个一个的改了源码
  • zz: 我去,楼主你真及时,我们今天上了新的HTTP2 push之后也发现速度曲线很奇怪,开始有200k/min,跟 另一台老的推送协议速度差不多,但是过了一会,立马降到只有几k /min,百思不得其解,我们还用了一个海外代理,在...
  • qi365: :mad: 很可恶,百度助纣为虐~
  • qi365: :? :shock: haha~ very good~