热门标签 | 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\' \' \')


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


推荐阅读
  • 服务器部署中的安全策略实践与优化
    服务器部署中的安全策略实践与优化 ... [详细]
  • DAO(Data Access Object)模式是一种用于抽象和封装所有对数据库或其他持久化机制访问的方法,它通过提供一个统一的接口来隐藏底层数据访问的复杂性。 ... [详细]
  • 从0到1搭建大数据平台
    从0到1搭建大数据平台 ... [详细]
  • 基于Net Core 3.0与Web API的前后端分离开发:Vue.js在前端的应用
    本文介绍了如何使用Net Core 3.0和Web API进行前后端分离开发,并重点探讨了Vue.js在前端的应用。后端采用MySQL数据库和EF Core框架进行数据操作,开发环境为Windows 10和Visual Studio 2019,MySQL服务器版本为8.0.16。文章详细描述了API项目的创建过程、启动步骤以及必要的插件安装,为开发者提供了一套完整的开发指南。 ... [详细]
  • 【并发编程】全面解析 Java 内存模型,一篇文章带你彻底掌握
    本文深入解析了 Java 内存模型(JMM),从基础概念到高级特性进行全面讲解,帮助读者彻底掌握 JMM 的核心原理和应用技巧。通过详细分析内存可见性、原子性和有序性等问题,结合实际代码示例,使开发者能够更好地理解和优化多线程并发程序。 ... [详细]
  • 本文介绍如何使用 Python 的 DOM 和 SAX 方法解析 XML 文件,并通过示例展示了如何动态创建数据库表和处理大量数据的实时插入。 ... [详细]
  • 原文网址:https:www.cnblogs.comysoceanp7476379.html目录1、AOP什么?2、需求3、解决办法1:使用静态代理4 ... [详细]
  • 本文详细介绍了 InfluxDB、collectd 和 Grafana 的安装与配置流程。首先,按照启动顺序依次安装并配置 InfluxDB、collectd 和 Grafana。InfluxDB 作为时序数据库,用于存储时间序列数据;collectd 负责数据的采集与传输;Grafana 则用于数据的可视化展示。文中提供了 collectd 的官方文档链接,便于用户参考和进一步了解其配置选项。通过本指南,读者可以轻松搭建一个高效的数据监控系统。 ... [详细]
  • 大类|电阻器_使用Requests、Etree、BeautifulSoup、Pandas和Path库进行数据抓取与处理 | 将指定区域内容保存为HTML和Excel格式
    大类|电阻器_使用Requests、Etree、BeautifulSoup、Pandas和Path库进行数据抓取与处理 | 将指定区域内容保存为HTML和Excel格式 ... [详细]
  • MySQL的查询执行流程涉及多个关键组件,包括连接器、查询缓存、分析器和优化器。在服务层,连接器负责建立与客户端的连接,查询缓存用于存储和检索常用查询结果,以提高性能。分析器则解析SQL语句,生成语法树,而优化器负责选择最优的查询执行计划。这一流程确保了MySQL能够高效地处理各种复杂的查询请求。 ... [详细]
  • 在使用 Cacti 进行监控时,发现已运行的转码机未产生流量,导致 Cacti 监控界面显示该转码机处于宕机状态。进一步检查 Cacti 日志,发现数据库中存在 SQL 查询失败的问题,错误代码为 145。此问题可能是由于数据库表损坏或索引失效所致,建议对相关表进行修复操作以恢复监控功能。 ... [详细]
  • 本文详细介绍了在MySQL中如何高效利用EXPLAIN命令进行查询优化。通过实例解析和步骤说明,文章旨在帮助读者深入理解EXPLAIN命令的工作原理及其在性能调优中的应用,内容通俗易懂且结构清晰,适合各水平的数据库管理员和技术人员参考学习。 ... [详细]
  • 在本文中,我们将探讨如何在Docker环境中高效地管理和利用数据库。首先,需要安装Docker Desktop以确保本地环境准备就绪。接下来,可以从Docker Hub中选择合适的数据库镜像,并通过简单的命令将其拉取到本地。此外,我们还将介绍如何配置和优化这些数据库容器,以实现最佳性能和安全性。 ... [详细]
  • 本指南详细介绍了在Linux环境中高效连接MySQL数据库的方法。用户可以通过安装并使用`mysql`客户端工具来实现本地连接,具体命令为:`mysql -u 用户名 -p 密码 -h 主机`。例如,使用管理员账户连接本地MySQL服务器的命令为:`mysql -u root -p pass`。此外,还提供了多种配置优化建议,以确保连接过程更加稳定和高效。 ... [详细]
  • 在Android应用开发中,实现与MySQL数据库的连接是一项重要的技术任务。本文详细介绍了Android连接MySQL数据库的操作流程和技术要点。首先,Android平台提供了SQLiteOpenHelper类作为数据库辅助工具,用于创建或打开数据库。开发者可以通过继承并扩展该类,实现对数据库的初始化和版本管理。此外,文章还探讨了使用第三方库如Retrofit或Volley进行网络请求,以及如何通过JSON格式交换数据,确保与MySQL服务器的高效通信。 ... [详细]
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社区 版权所有