分布式任务调度框架 Azkaban —— Flow 1.0 的使用

1、简介

Azkaban 主要经过界面上传配置文件来进行任务的调度。它有两个重要的概念：

• Job： 你须要执行的调度任务；
• Flow：一个获取多个 Job 及它们之间的依赖关系所组成的图表叫作 Flow。

目前 Azkaban 3.x 同时支持 Flow 1.0 和 Flow 2.0，本文主要讲解 Flow 1.0 的使用，下一篇文章会讲解 Flow 2.0 的使用。

2、基本任务调度

2.1 新建项目

在 Azkaban 主界面能够建立对应的项目：

2.2 任务配置

新建任务配置文件 Hello-Azkaban.job，内容以下。这里的任务很简单，就是输出一句 'Hello Azkaban!' ：

#command.job
type=command
command=echo 'Hello Azkaban!'

2.3 打包上传

将 Hello-Azkaban.job 打包为 zip 压缩文件：

经过 Web UI 界面上传：

上传成功后能够看到对应的 Flows：

2.4 执行任务

点击页面上的 Execute Flow 执行任务：

2.5 执行结果

点击 detail 能够查看到任务的执行日志：

3、多任务调度

3.1 依赖配置

这里假设咱们有五个任务（TaskA——TaskE）,D 任务须要在 A，B，C 任务执行完成后才能执行，而 E 任务则须要在 D 任务执行完成后才能执行，这种状况下须要使用 dependencies 属性定义其依赖关系。各任务配置以下：

Task-A.job :

type=command
command=echo 'Task A'

Task-B.job :

type=command
command=echo 'Task B'

Task-C.job :

type=command
command=echo 'Task C'

Task-D.job :

type=command
command=echo 'Task D'
dependencies=Task-A,Task-B,Task-C

Task-E.job :

type=command
command=echo 'Task E'
dependencies=Task-D

3.2 压缩上传

压缩后进行上传，这里须要注意的是一个 Project 只能接收一个压缩包，这里我还沿用上面的 Project，默认后面的压缩包会覆盖前面的压缩包：

3.3 依赖关系

多个任务存在依赖时，默认采用最后一个任务的文件名做为 Flow 的名称，其依赖关系如图：

3.4 执行结果

从这个案例能够看出，Flow1.0 没法经过一个 job 文件来完成多个任务的配置，可是 Flow 2.0 就很好的解决了这个问题。

4、调度HDFS做业

步骤与上面的步骤一致，这里以查看 HDFS 上的文件列表为例。命令建议采用完整路径，配置文件以下：

type=command
command=/usr/app/hadoop-2.6.0-cdh5.15.2/bin/hadoop fs -ls /

执行结果：

5、调度MR做业

MR 做业配置：

type=command
command=/usr/app/hadoop-2.6.0-cdh5.15.2/bin/hadoop jar /usr/app/hadoop-2.6.0-cdh5.15.2/share/hadoop/mapreduce/hadoop-mapreduce-examples-2.6.0-cdh5.15.2.jar pi 3 3

执行结果：

6、调度Hive做业

做业配置：

type=command
command=/usr/app/hive-1.1.0-cdh5.15.2/bin/hive -f 'test.sql'

其中 test.sql 内容以下，建立一张雇员表，而后查看其结构：

CREATE DATABASE IF NOT EXISTS hive;
use hive;
drop table if exists emp;
CREATE TABLE emp(
empno int,
ename string,
job string,
mgr int,
hiredate string,
sal double,
comm double,
deptno int
) ROW FORMAT DELIMITED FIELDS TERMINATED BY '\t';
-- 查看 emp 表的信息
desc emp;

打包的时候将 job 文件与 sql 文件一并进行打包：

执行结果以下：

7、在线修改做业配置

在测试时，咱们可能须要频繁修改配置，若是每次修改都要从新打包上传，这会比较麻烦。因此 Azkaban 支持配置的在线修改，点击须要修改的 Flow，就能够进入详情页面：

在详情页面点击 Eidt 按钮能够进入编辑页面：

在编辑页面能够新增配置或者修改配置：

附：可能出现的问题

若是出现如下异常，多半是由于执行主机内存不足，Azkaban 要求执行主机的可用内存必须大于 3G 才能执行任务：

Cannot request memory (Xms 0 kb, Xmx 0 kb) from system for job

若是你的执行主机没办法增大内存，那么能够经过修改 plugins/jobtypes/ 目录下的 commonprivate.properties 文件来关闭内存检查，配置以下：

memCheck.enabled=false

更多大数据系列文章能够参见 GitHub 开源项目： 大数据入门指南