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

hadoop2.10集群+flinkha搭建

hadoop2.10flink环境搭建Hadoop集群搭建1.安装配置JDK1.下载jdkhttps:file.zhanghail.cnjdk-9.0.1_linux-x6

hadoop2.10+flink环境搭建


Hadoop集群搭建


1.安装配置JDK


  • 1.下载jdk

https://file.zhanghail.cn/jdk-9.0.1_linux-x64_bin.tar.gz

  • 2.解压jdk

tar xf jdkxxxxx.tar.gz -C /usr/local
ln -s /usr/local/jadkxx /usr/local/java

  • 3.设置环境变量

cat > /etc/profile <export JAVA_HOME&#61;/usr/lib/jdk-9.0.1
export JRE_HOME&#61;${JAVA_HOME}/jre
export CLASSPATH&#61;.:${JAVA_HOME}/lib:${JRE_HOME}/lib
export PATH&#61;${JAVA_HOME}/bin:$PATH
EOF

2.配置所有节点互相免密登录

ssh-keygen 一路回车
cat /root/.ssh/id_rsa.pub >> /root/.ssh/authorized_keys
......

3.修改主机名、hosts劫持信息

vim /etc/hosts
10.0.0.10 hadoop-master
10.10.0.7 slave1
10.10.0.8 slave2
10.10.0.9 slave3

4.Hadoop环境搭建


  • 1.安装包下载
    下载hadoop到mastar节点

wget https://file.zhanghail.cn/hadoop-2.10.0.tar.gz

  • 2.解压到/hadoop目录下

mkdir /hadoop
tar -zxvf hadoop-2.10.0.tar.gz -C /hadoop/

  • 3.进入hadoop目录

cd /hadoop

  • 4.配置hadoop-master的环境变量
    cat > /etc/profile < export HADOOP_HOME&#61;/hadoop/hadoop-2.10.0
    export PATH&#61;PATH:PATH:PATH:HADOOP_HOME/bin
    EOF
  • 5.生效环境变量

source /etc/profile

  • 6.修改配置文件
    配置core-site.xml&#xff0c;执行vim etc/hadoop/core-site.xml命令&#xff0c;通过fs.defaultFS指定NameNode

hadoop.tmp.dirfile:/hadoop/data/tmpAbase for other temporary directories.fs.default.namehdfs://hadoop-master:9000


  • 7.配置hdfs.-site.xml&#xff0c;执行vim etc/hadoop/hdfs-site.xml

dfs.replication3 ##此处为几个slave节点dfs.name.dir/data/hadoop/data/hdfs/namedfs.data.dir/data/hadoop/data/hdfs/data


  • 8.配置mapred-site.xml
    先复制mapred-site.xml.template为mapred-site.xml&#xff0c;在进行修改

cp etc/hadoop/mapred-site.xml.template etc/hadoop/mapred-site.xmlvim /etc/hadoop/mapred-site.xml
mapreduce.framework.nameyarnmapred.job.trackerhttp://hadoop-master:9001


  • 9.配置masters、slaves

vim etc/hadoop/masters
hadoop-mastervim /etc/slaves
slave1
slave2
slave3

3.配置所有从节点


  • 1.将主节点上的hadoop文件夹依次拷贝到所有从节点的相同目录下&#xff1a;

scp -r /hadoop/ hadoop-slave1:/data
scp -r /hadoop/ hadoop-slave2:/data
scp -r /hadoop/ hadoop-slave3:/data

  • 2.对所有从节点配置环境变量

export HADOOP_HOME&#61;/hadoop/hadoop-2.10.0
export PATH&#61;$PATH:$HADOOP_HOME/bin

4.启动集群


  • 1.格式化HDFS文件系统

在master节点执行&#xff1a;
hadoop namenode -format ##切忌重复执行

  • 2.启动hadoop集群

sbin/start-all.sh

  • 3.若启动无报错&#xff0c;访问http://hadoop-master:50070/即可访问hadoop集群

Flink standalone集群HA高可用搭建


1.下载flink (hadoop对应版本的)

wget https://file.zhanghail.cn/flink-1.10.0-bin-scala_2.11.tgz

2.安装flink


  • 1.解压 flink-1.10.0-bin-scala_2.11.tgz 到 /opt 目录

sudo tar -zxvf flink-1.10.0-bin-scala_2.11.tgz -C /opt
解压后可修改目录名称为flink

  • 2.修改环境变量

export FLINK_HOME&#61;/opt/flink
export PATH&#61;$FLINK_HOME/bin:$PATH加载环境变量
source /etc/profile

3.配置flink


  • 修改配置文件flink-conf.yaml

vim /opt/flink/conf/flink-conf.yaml
jobmanager.rpc.address: hadoop-masterhigh-availability: zookeeper
high-availability.storageDir: hdfs:///flink/ha/
high-availability.zookeeper.quorum: hadoop-master:2181,slave1:2181,slave2:2181,slave3:2181

  • 配置master

master:8081
slave1:8081

  • 配置slave

slave1
slave2
slave3

  • 将配置文件发送至各节点

scp /opt/flink slave1:/opt/
scp /opt/flink slave2:/opt/
scp /opt/flink slave3:/opt/

  • 各个结点启动

/opt/flink/bin/start-cluster.sh


推荐阅读
  • Hadoop2.6.0 + 云centos +伪分布式只谈部署
    3.0.3玩不好,现将2.6.0tar.gz上传到usr,chmod-Rhadoop:hadophadoop-2.6.0,rm掉3.0.32.在etcp ... [详细]
  •     这里使用自己编译的hadoop-2.7.0版本部署在windows上,记得几年前,部署hadoop需要借助于cygwin,还需要开启ssh服务,最近发现,原来不需要借助cy ... [详细]
  • HDFS2.x新特性
    一、集群间数据拷贝scp实现两个远程主机之间的文件复制scp-rhello.txtroothadoop103:useratguiguhello.txt推pushscp-rr ... [详细]
  • Annotation的大材小用
    为什么80%的码农都做不了架构师?最近在开发一些通用的excel数据导入的功能,由于涉及到导入的模块很多,所以开发了一个比较通用的e ... [详细]
  • 安装mysqlclient失败解决办法
    本文介绍了在MAC系统中,使用django使用mysql数据库报错的解决办法。通过源码安装mysqlclient或将mysql_config添加到系统环境变量中,可以解决安装mysqlclient失败的问题。同时,还介绍了查看mysql安装路径和使配置文件生效的方法。 ... [详细]
  • VScode格式化文档换行或不换行的设置方法
    本文介绍了在VScode中设置格式化文档换行或不换行的方法,包括使用插件和修改settings.json文件的内容。详细步骤为:找到settings.json文件,将其中的代码替换为指定的代码。 ... [详细]
  • 在说Hibernate映射前,我们先来了解下对象关系映射ORM。ORM的实现思想就是将关系数据库中表的数据映射成对象,以对象的形式展现。这样开发人员就可以把对数据库的操作转化为对 ... [详细]
  • 本文讨论了在Spring 3.1中,数据源未能自动连接到@Configuration类的错误原因,并提供了解决方法。作者发现了错误的原因,并在代码中手动定义了PersistenceAnnotationBeanPostProcessor。作者删除了该定义后,问题得到解决。此外,作者还指出了默认的PersistenceAnnotationBeanPostProcessor的注册方式,并提供了自定义该bean定义的方法。 ... [详细]
  • eclipse学习(第三章:ssh中的Hibernate)——11.Hibernate的缓存(2级缓存,get和load)
    本文介绍了eclipse学习中的第三章内容,主要讲解了ssh中的Hibernate的缓存,包括2级缓存和get方法、load方法的区别。文章还涉及了项目实践和相关知识点的讲解。 ... [详细]
  • ZSI.generate.Wsdl2PythonError: unsupported local simpleType restriction ... [详细]
  • XML介绍与使用的概述及标签规则
    本文介绍了XML的基本概念和用途,包括XML的可扩展性和标签的自定义特性。同时还详细解释了XML标签的规则,包括标签的尖括号和合法标识符的组成,标签必须成对出现的原则以及特殊标签的使用方法。通过本文的阅读,读者可以对XML的基本知识有一个全面的了解。 ... [详细]
  • Java验证码——kaptcha的使用配置及样式
    本文介绍了如何使用kaptcha库来实现Java验证码的配置和样式设置,包括pom.xml的依赖配置和web.xml中servlet的配置。 ... [详细]
  • flowable工作流 流程变量_信也科技工作流平台的技术实践
    1背景随着公司业务发展及内部业务流程诉求的增长,目前信息化系统不能够很好满足期望,主要体现如下:目前OA流程引擎无法满足企业特定业务流程需求,且移动端体 ... [详细]
  • 本文介绍了Android 7的学习笔记总结,包括最新的移动架构视频、大厂安卓面试真题和项目实战源码讲义。同时还分享了开源的完整内容,并提醒读者在使用FileProvider适配时要注意不同模块的AndroidManfiest.xml中配置的xml文件名必须不同,否则会出现问题。 ... [详细]
  • 本文介绍了5个基本Linux命令行工具的现代化替代品,包括du、top和ncdu。这些替代品在功能上进行了改进,提高了可用性,并且适用于现代化系统。其中,ncdu是du的替代品,它提供了与du类似的结果,但在一个基于curses的交互式界面中,重点关注占用磁盘空间较多的目录。 ... [详细]
author-avatar
淑敏惟雄988
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有