热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

大数据集群启动

hadoop@master~]$1、hadoop启动start-all.sh停止stop-all.sh2、hivehive3、zookeepercdhom


hadoop@master ~]$

1、hadoop 启动start-all.sh 停止 stop-all.sh

2、hive hive

3、zookeeper

cd /home/hadoop
启动 命令(每台机器都启动)
zookeeper-3.4.14/bin/zkServer.sh start 日志会在启动目录下 生成 zookeeper.out
查看状态命令
zookeeper-3.4.14/bin/zkServer.sh status

4、sqoop

验证 sqoop是否可用

sqoop import --connect jdbc:mysql://192.168.91.112:3306/bgdmysqldb --username root --password \'2019_Mysql\' --table dh_call_info2 --fields-terminated-by \'\t\' --num-mappers 1 --hive-import --hive-database rdw --hive-table dh_call_info2 --delete-target-dir

验证:select * from rdw.dh_call_info2;

5、azkaban

 

6、spark集群启动
启动hive的元数据服务# hive --service metastore
备注;jps 会出现一个名为“RunJar”的进程。

cd /home/hadoop/spark-244

bin/spark-sql --master yarn
use rdw;
select * from dh_call_info2;

7、habse集群

/home/hadoop/hbase-222/bin/start-hbase.sh
jps
39596 HMaster
39766 HRegionServer

cd /home/hadoop/hbase-222

bin/hbase shell

执行 get \'t1\',\'rowkey001\', {COLUMN=>\'f1:col1\'}

8、kafka集群
启动 kafka 每台机器都启动
cd /home/hadoop/kafka-212-230

bin/kafka-server-start.sh config/server.properties

启动控制台生产者

bin/kafka-console-producer.sh --broker-list 192.168.91.112:9092 --topic topic_test1

启动控制台消费者
bin/kafka-console-consumer.sh --bootstrap-server 192.168.91.113:9092 --topic topic_test1 --from-beginning

在生产者控制台输入hello world


9、flink 集群

启动、flink集群
start-cluster.sh

jps
30436 StandaloneSessionClusterEntrypoint 主节点
29516 TaskManagerRunner 子节点


cd /home/hadoop/flink-191

运行示例 注意在【cd /home/hadoop/flink-191】目录下运行,否则可能找不到 文件
flink run examples/streaming/WordCount.jar

打开web管理页面
http://master:8091

关闭flink集群
stop-cluster.sh

+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++

通过SSH 统一管理 集群的启动和停止
更多命令参考:https://www.cnblogs.com/youngerger/p/9104144.html


在主服务器创建 文件 vi bigdata-start.sh

内容如下:


start-all.sh
cd /home/hadoop
zookeeper-3.4.14/bin/zkServer.sh start
ssh hadoop@slave1 "cd /home/hadoop;zookeeper-3.4.14/bin/zkServer.sh start;exit"
ssh hadoop@slave2 "cd /home/hadoop;zookeeper-3.4.14/bin/zkServer.sh start;exit"
/home/hadoop/hbase-222/bin/start-hbase.sh
cd /home/hadoop/kafka-212-230
nohup bin/kafka-server-start.sh config/server.properties &
ssh hadoop@slave1 "cd /home/hadoop/kafka-212-230;nohup bin/kafka-server-start.sh config/server.properties >>kafka-nohup.out 2>&1 &"
ssh hadoop@slave2 "cd /home/hadoop/kafka-212-230;nohup bin/kafka-server-start.sh config/server.properties >>kafka-nohup.out 2>&1 &"
start-cluster.sh
exit 1

在主服务器创建文件 vi bigdata-stop.sh

内容如下:

###master stop
stop-all.sh
/home/hadoop/zookeeper-3.4.14/bin/zkServer.sh stop
/home/hadoop/kafka-212-230/bin/kafka-server-stop.sh
kill -9 $(ps -ef|grep HMaster|gawk \'$0 !~/grep/ {print $2}\' |tr -s \'\n\' \' \')
kill -9 $(ps -ef|grep HRegionServer|gawk \'$0 !~/grep/ {print $2}\' |tr -s \'\n\' \' \')
kill -9 $(ps -ef|grep Kafka|gawk \'$0 !~/grep/ {print $2}\' |tr -s \'\n\' \' \')
stop-cluster.sh


####slave1 stop
# you could exe remote mashine\'s sh file too.
#ssh hadoop@slave1 "/home/hadoop/bigdata-stop-slave1.sh"
#ssh hadoop@slave2 "/home/hadoop/bigdata-stop-slave2.sh"

#
ssh hadoop@slave1

ssh hadoop@slave2

exit 1


在主服务器创建文件 vi /home/hadoop/bigdata-stop-slave.sh

内容如下:

kill -9 $(ps -ef|grep Kafka|gawk \'$0 !~/grep/ {print $2}\' |tr -s \'\n\' \' \')
kill -9 $(ps -ef|grep HMaster|gawk \'$0 !~/grep/ {print $2}\' |tr -s \'\n\' \' \')
kill -9 $(ps -ef|grep HRegionServer|gawk \'$0 !~/grep/ {print $2}\' |tr -s \'\n\' \' \')
kill -9 $(ps -ef|grep QuorumPeerMain|gawk \'$0 !~/grep/ {print $2}\' |tr -s \'\n\' \' \')
kill -9 $(ps -ef|grep ZKMainServer|gawk \'$0 !~/grep/ {print $2}\' |tr -s \'\n\' \' \')


++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++


推荐阅读
  • 关键词:Golang, Cookie, 跟踪位置, net/http/cookiejar, package main, golang.org/x/net/publicsuffix, io/ioutil, log, net/http, net/http/cookiejar ... [详细]
  • 本文介绍了在sqoop1.4.*版本中,如何实现自定义分隔符的方法及步骤。通过修改sqoop生成的java文件,并重新编译,可以满足实际开发中对分隔符的需求。具体步骤包括修改java文件中的一行代码,重新编译所需的hadoop包等。详细步骤和编译方法在本文中都有详细说明。 ... [详细]
  • 本文介绍了Hive常用命令及其用途,包括列出数据表、显示表字段信息、进入数据库、执行select操作、导出数据到csv文件等。同时还涉及了在AndroidManifest.xml中获取meta-data的value值的方法。 ... [详细]
  • 本文详细介绍了SQL日志收缩的方法,包括截断日志和删除不需要的旧日志记录。通过备份日志和使用DBCC SHRINKFILE命令可以实现日志的收缩。同时,还介绍了截断日志的原理和注意事项,包括不能截断事务日志的活动部分和MinLSN的确定方法。通过本文的方法,可以有效减小逻辑日志的大小,提高数据库的性能。 ... [详细]
  • GetWindowLong函数
    今天在看一个代码里头写了GetWindowLong(hwnd,0),我当时就有点费解,靠,上网搜索函数原型说明,死活找不到第 ... [详细]
  • CSS3选择器的使用方法详解,提高Web开发效率和精准度
    本文详细介绍了CSS3新增的选择器方法,包括属性选择器的使用。通过CSS3选择器,可以提高Web开发的效率和精准度,使得查找元素更加方便和快捷。同时,本文还对属性选择器的各种用法进行了详细解释,并给出了相应的代码示例。通过学习本文,读者可以更好地掌握CSS3选择器的使用方法,提升自己的Web开发能力。 ... [详细]
  • 本文详细介绍了在ASP.NET中获取插入记录的ID的几种方法,包括使用SCOPE_IDENTITY()和IDENT_CURRENT()函数,以及通过ExecuteReader方法执行SQL语句获取ID的步骤。同时,还提供了使用这些方法的示例代码和注意事项。对于需要获取表中最后一个插入操作所产生的ID或马上使用刚插入的新记录ID的开发者来说,本文提供了一些有用的技巧和建议。 ... [详细]
  • ubuntu用sqoop将数据从hive导入mysql时,命令: ... [详细]
  • CEPH LIO iSCSI Gateway及其使用参考文档
    本文介绍了CEPH LIO iSCSI Gateway以及使用该网关的参考文档,包括Ceph Block Device、CEPH ISCSI GATEWAY、USING AN ISCSI GATEWAY等。同时提供了多个参考链接,详细介绍了CEPH LIO iSCSI Gateway的配置和使用方法。 ... [详细]
  • 本文介绍了在Ubuntu下制作deb安装包及离线安装包的方法,通过备份/var/cache/apt/archives文件夹中的安装包,并建立包列表及依赖信息文件,添加本地源,更新源列表,可以在没有网络的情况下更新系统。同时提供了命令示例和资源下载链接。 ... [详细]
  • 大数据Hadoop生态(20)MapReduce框架原理OutputFormat的开发笔记
    本文介绍了大数据Hadoop生态(20)MapReduce框架原理OutputFormat的开发笔记,包括outputFormat接口实现类、自定义outputFormat步骤和案例。案例中将包含nty的日志输出到nty.log文件,其他日志输出到other.log文件。同时提供了一些相关网址供参考。 ... [详细]
  • 基于移动平台的会展导游系统APP设计与实现的技术介绍与需求分析
    本文介绍了基于移动平台的会展导游系统APP的设计与实现过程。首先,对会展经济和移动互联网的概念进行了简要介绍,并阐述了将会展引入移动互联网的意义。接着,对基础技术进行了介绍,包括百度云开发环境、安卓系统和近场通讯技术。然后,进行了用户需求分析和系统需求分析,并提出了系统界面运行流畅和第三方授权等需求。最后,对系统的概要设计进行了详细阐述,包括系统前端设计和交互与原型设计。本文对基于移动平台的会展导游系统APP的设计与实现提供了技术支持和需求分析。 ... [详细]
  • OpenMap教程4 – 图层概述
    本文介绍了OpenMap教程4中关于地图图层的内容,包括将ShapeLayer添加到MapBean中的方法,OpenMap支持的图层类型以及使用BufferedLayer创建图像的MapBean。此外,还介绍了Layer背景标志的作用和OMGraphicHandlerLayer的基础层类。 ... [详细]
  • Jquery 跨域问题
    为什么80%的码农都做不了架构师?JQuery1.2后getJSON方法支持跨域读取json数据,原理是利用一个叫做jsonp的概念。当然 ... [详细]
  • 使用freemaker生成Java代码的步骤及示例代码
    本文介绍了使用freemaker这个jar包生成Java代码的步骤,通过提前编辑好的模板,可以避免写重复代码。首先需要在springboot的pom.xml文件中加入freemaker的依赖包。然后编写模板,定义要生成的Java类的属性和方法。最后编写生成代码的类,通过加载模板文件和数据模型,生成Java代码文件。本文提供了示例代码,并展示了文件目录结构。 ... [详细]
author-avatar
手机用户2502937963
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有