• Azkaban


    集群模式安装

    1)解压并安装

    1.将azkaban-db-3.84.4.tar.gz,azkaban-exec-server-3.84.4.tar.gz,azkaban-web-server-3.84.4.tar.gz上传到hadoop102的/opt/software路径

    2.新建/opt/module/azkaban目录,并将所有tar包解压到这个目录下

    3.解压azkaban-db-3.84.4.tar.gz、 azkaban-exec-server-3.84.4.tar.gz和azkaban-web-server-3.84.4.tar.gz到/opt/module/azkaban目录下

    4.进入到/opt/module/azkaban目录,依次修改名称

    1. [atguigu@hadoop102 software]$ ll
    2. 总用量 35572
    3. -rw-r--r--. 1 atguigu atguigu 6433 4月 18 17:24 azkaban-db-3.84.4.tar.gz
    4. -rw-r--r--. 1 atguigu atguigu 16175002 4月 18 17:26 azkaban-exec-server-3.84.4.tar.gz
    5. -rw-r--r--. 1 atguigu atguigu 20239974 4月 18 17:26 azkaban-web-server-3.84.4.tar.gz
    6. [atguigu@hadoop102 software]$ mkdir /opt/module/azkaban
    7. [atguigu@hadoop102 software]$ tar -zxvf azkaban-db-3.84.4.tar.gz -C /opt/module/azkaban/
    8. [atguigu@hadoop102 software]$ tar -zxvf azkaban-exec-server-3.84.4.tar.gz -C /opt/module/azkaban/
    9. [atguigu@hadoop102 software]$ tar -zxvf azkaban-web-server-3.84.4.tar.gz -C /opt/module/azkaban/
    10. [atguigu@hadoop102 azkaban]$ mv azkaban-exec-server-3.84.4/ azkaban-exec
    11. [atguigu@hadoop102 azkaban]$ mv azkaban-web-server-3.84.4/ azkaban-web

    配置Mysql

    1.启动Mysql创建azkaban用户并赋予权限

    mysql> create database azkaban;

    2.创建Azkaban表,完成后退出MySQL

    1. mysql> use azkaban;
    2. mysql> source /opt/module/azkaban/azkaban-db-3.84.4/create-all-sql-3.84.4.sql
    3. mysql> quit;

    3.更改MySQL包大小;防止Azkaban连接MySQL阻塞,并重启Mysql

    1. -- 在[mysqld]下面加一行max_allowed_packet=1024M
    2. [mysqld]
    3. max_allowed_packet=1024M
    4. [atguigu@hadoop102 software]$ sudo systemctl restart mysqld

    配置Executor Server

    1.编辑azkaban.properties

    1. [atguigu@hadoop102 azkaban]$ vim /opt/module/azkaban/azkaban-exec/conf/azkaban.properties
    2. -- 修改如下标红的属性
    3. #...
    4. default.timezone.id=Asia/Shanghai
    5. #...
    6. azkaban.webserver.url=http://hadoop102:8081
    7. executor.port=12321
    8. #...
    9. database.type=mysql
    10. mysql.port=3306
    11. mysql.host=hadoop102
    12. mysql.database=azkaban
    13. mysql.user=azkaban
    14. mysql.password=000000
    15. mysql.numconnections=100

    2.同步azkaban-exec到所有节点

    [atguigu@hadoop102 azkaban]$ xsync /opt/module/azkaban/azkaban-exec

    3.必须进入到/opt/module/azkaban/azkaban-exec路径,分别在三台机器上,启动executor server

    1. [atguigu@hadoop102 azkaban-exec]$ bin/start-exec.sh
    2. [atguigu@hadoop103 azkaban-exec]$ bin/start-exec.sh
    3. [atguigu@hadoop104 azkaban-exec]$ bin/start-exec.sh

    如果在/opt/module/azkaban/azkaban-exec目录下出现executor.port文件,说明启动成功

    4.下面激活executor

    1. [atguigu@hadoop102 azkaban-exec]$ curl -G "hadoop102:12321/executor?action=activate" && echo
    2. [atguigu@hadoop103 azkaban-exec]$ curl -G "hadoop103:12321/executor?action=activate" && echo
    3. [atguigu@hadoop104 azkaban-exec]$ curl -G "hadoop104:12321/executor?action=activate" && echo

    配置Web Server

    1.编辑azkaban.properties

    1. [atguigu@hadoop102 azkaban]$ vim /opt/module/azkaban/azkaban-web/conf/azkaban.properties
    2. -- 修改如下属性
    3. default.timezone.id=Asia/Shanghai
    4. ...
    5. database.type=mysql
    6. mysql.port=3306
    7. mysql.host=hadoop102
    8. mysql.database=azkaban
    9. mysql.user=azkaban
    10. mysql.password=000000
    11. mysql.numconnections=100
    12. ...
    13. azkaban.executorselector.filters=StaticRemainingFlowSize,CpuStatus

    2.修改azkaban-users.xml文件。添加atguigu用户

    1. [atguigu@hadoop102 azkaban-web]$ vim /opt/module/azkaban/azkaban-web/conf/azkaban-users.xml
    2. <azkaban-users>
    3. <user groups="azkaban" password="azkaban" roles="admin" username="azkaban"/>
    4. <user password="metrics" roles="metrics" username="metrics"/>
    5. <user password="atguigu" roles="admin" username="atguigu"/>
    6. <role name="admin" permissions="ADMIN"/>
    7. <role name="metrics" permissions="METRICS"/>
    8. azkaban-users>

    3.必须进入到hadoop102的/opt/module/azkaban/azkaban-web路径,启动web server

    4.访问http://hadoop102:8081,并用atguigu用户登陆

  • 相关阅读:
    ctrl+k,ctrl+l无法切换到时限文件
    java调用python的方法
    生产脚本1
    java基于ssm+vue高校人事管理系统
    【vue.js】路由使用与Node.js下载安装之环境配置
    3分钟带你掌握Spring Boot中的定时调度服务
    区块链为化解信任危机带来新契机
    iapp卸载指定软件代码,iapp删除文件夹代码
    React - redux 使用(由浅入深)
    Flink系列之Flink中RestartStrategy重启策略和FailoverStrategy故障转移策略
  • 原文地址:https://blog.csdn.net/weixin_63816398/article/details/126336225