Azkaban实战-Hive脚本任务

1.创建job描述文件和hive脚本

(1)Hive脚本：student.sql

vim student.sql

添加内容：

use default;
drop table student;
create table student(id int, name string)
row format delimited fields terminated by '\t';
load data local inpath '/opt/module/datas/student.txt' into table student;
insert overwrite local directory '/opt/module/datas/student'
row format delimited fields terminated by '\t'
select * from student;

(2)Job描述文件：hive.job

vi hive.job

添加内容：

#hive job
type=command
command=/opt/module/hive-1.2.1/bin/hive -f /opt/module/azkaban/jobs/student.sql

2.将所有job资源文件打到一个zip包中

3.在azkaban的web管理界面创建工程并上传zip包

4.启动job：

5.查看结果

cat /opt/module/datas/student/000000_0

打赏