Spark集群试运行

下面试运行Spark。
1)在Master主机上,分别启动Hadoop与Spark。

cd /usr/local/hadoop/sbin/./start-all.shcd /usr/local/spark/sbin./start-all.sh

**2)检查Master与Worker进程是否在各自节点上启动。在Master主机上,执行命令jps,**如图1-5所示。

图1-5 在Master主机上执行jps命令
在Worker节点上,以Worker1为

执行命令jps,如图1-6所示。

图1-6 在Worker节点上执行jps命令
从图1-6中可以清晰地看到,Master进程与Worker及相关进程在各自节点上成功运行,Hadoop与Spark运行正常。
3)通过Spark Web UI查看集群状态。在浏览器中输入Master的IP与端口,打开Spark Web UI,如图1-7所示。

Spark Web UI界面
从图1-7中可以看到,当集群内仅有一个Worker节点时,Spark Web UI显示该节点处于Alive状态,CPU Cores为1,内存为1GB。此页面会列出集群中所有启动后的Worker节点及应用的信息。
4)运行样例。Spark自带了一些样例程序可供试运行。在Spark根目录下,example/src/main文件夹中存放着Scala、Java、Python及用R语言编写的样例,
用户可以运行其中的某个样例程序。
先拷贝到Spark根目录下,然后执行bin/run-example [class] [params]即可。
例如可以在Master主机命令行执行:
./run-example SparkPi 10
然后可以看到该应用的输出,在Spark Web UI上也可以查看应用的状态及其他信息。

Spark集群试运行相关推荐

  1. spark 序列化错误 集群提交时_【问题解决】本地提交任务到Spark集群报错:Initial job has not accepted any resources...

    本地提交任务到Spark集群报错:Initial job has not accepted any resources 错误信息如下: 18/04/17 18:18:14 INFO TaskSched ...

  2. spark集群使用hanlp进行分布式分词操作说明

    本篇分享一个使用hanlp分词的操作小案例,即在spark集群中使用hanlp完成分布式分词的操作,文章整理自[qq_33872191]的博客,感谢分享!以下为全文:   分两步: 第一步:实现han ...

  3. GIS+=地理信息+云计算技术——Spark集群部署

    第一步:安装软件         Spark 1.5.4:wget http://www.apache.org/dyn/closer.lua/spark/spark-1.5.2/spark-1.5.2 ...

  4. Spark集群启动时worker节点启不起来

    在spark集群中使用命令: sbin/start-all.sh 启动集群时报错: starting org.apache.spark.deploy.master.Master, logging to ...

  5. 实现Spark集群部署 这些公司都经历了什么?

    咨询公司获得了客户关于Spark评价的 "实质性"调查.但这项技术尚未成熟,企业用户中关于Spark集群的产品相对较少.他说,"我们对这项技术很感兴趣,Spark是否转化 ...

  6. Spark集群基于Zookeeper的HA搭建部署笔记(转)

    原文链接:Spark集群基于Zookeeper的HA搭建部署笔记 1.环境介绍 (1)操作系统RHEL6.2-64 (2)两个节点:spark1(192.168.232.147),spark2(192 ...

  7. Spark集群搭建中的问题

    参照<Spark实战高手之路>学习的,书籍电子版在51CTO网站 资料链接 Hadoop下载[链接](http://archive.apache.org/dist/hadoop/core/ ...

  8. spark 集群单词统计_最近Kafka这么火,聊一聊Kafka:Kafka与Spark的集成

    Spark 编程模型 在Spark 中, 我们通过对分布式数据集的操作来表达计算意图 ,这些计算会自动在集群上 井行执行 这样的数据集被称为弹性分布式数据集 Resilient Distributed ...

  9. 学习笔记Spark(二)—— Spark集群的安装配置

    一.我的软件环境 二.Spark集群拓扑 2.1.集群规模 192.168.128.10 master 1.5G ~2G内存.20G硬盘.NAT.1~2核 : 192.168.128.11 node1 ...

最新文章

  1. pymysql的使用心得(1)------小细节,注意!
  2. if not exist Oracle,oracle 兑现 if not exist 方法
  3. docker入门与实践之【04-使用dockerfile定制镜像】
  4. Error Message - 400 File is not contained in a resource root
  5. link和@import的区别
  6. c语言中Gretchen函数的功能,听过很多的歌的音乐达人给我推荐一下
  7. php 前置操作方法,前置操作-THINKPHP 5.0 手册最新版
  8. ipv4广播地址怎么填_什么是IP地址?IP地址有什么用?网络工程师来告诉你
  9. XSLT的处理模型(1)
  10. 5-functools模块
  11. google地图距离算法_谷歌地图计算两个坐标点的距离函数
  12. 揭秘;抖音美妆账号如何做?如何玩转抖音美妆类运营:国仁楠哥
  13. JAVA面试题100道
  14. json文件保存与读取
  15. 求1!+2!+3!+.....+20!
  16. @kubernetes(k8s)pod服务探针(健康检查)及回调钩子HOOK详解
  17. 在前端弹出后台的错误信息
  18. 离散数学-集合:2、集合的基本运算
  19. 开启电脑替我记忆之路
  20. 华为手机备份的通讯录是什么文件_华为手机资料备份与恢复教程(含联系人短信图片程序等)...

热门文章

  1. input验证码框,输入非数字或非12位时,红框提示;每4位加一个空格
  2. Udp、Tcp、Http Socket
  3. Mvc5 EF6 CodeFirst Mysql (一) 新建一个Mvc项目并使用EF连接到Mysql数据库
  4. python websocket实现消息推送_python Django websocket 实时消息推送
  5. python pathos_python运行多线程库pathos时,pymongo递归深度溢出
  6. iOS开发之UITableView全面解析
  7. 博客文件第二部分 Linux Shell高级编程技巧——第一章 深入讨论
  8. PHP32向右位移2位是多少,PHP的二进制位移操作
  9. Java中只存在值传递
  10. ×××技术漫谈之IPSec(附MPLS)