ITPub博客

首页 > 大数据 > Hadoop > Oozie API调用Hue JOB

Oozie API调用Hue JOB

原创 Hadoop 作者:tom_fans 时间:2017-06-08 15:10:21 0 删除 编辑
package com.isesol.zeppelin;


import java.util.Properties;


import org.apache.oozie.client.OozieClient;
import org.apache.oozie.client.WorkflowJob.Status;


public class oozie {


public static void main(String[] args){

OozieClient wc = new OozieClient("http://10.215.4.164:11000/oozie"); 
        Properties conf = wc.createConfiguration(); 
        conf.setProperty("nameNode", "hdfs://nameservice1"); 
        conf.setProperty("oozie.wf.application.path", "hdfs://nameservice1/user/hue/oozie/workspaces/hue-oozie-1496904130.34"); 
        conf.setProperty("jobTracker", "yarnRM"); 
        conf.setProperty("mapreduce.job.user.name", "hdfs");
        conf.setProperty("user.name", "hdfs");
        //conf.setProperty("hue-id-w", "496");
        conf.setProperty("oozie.use.system.libpath", "true");
        conf.setProperty("dryrun", "false");
        conf.setProperty("fileName", "/tmp/b.gz");
        conf.setProperty("appId", "1");
        conf.setProperty("machine_tool", "1111111");
        conf.setProperty("bizId", "fdfsdfdfd");


        try { 
            String jobId = wc.run(conf); 
            System.out.println(jobId);


            
        } catch (Exception e) {
            e.printStackTrace();
        }
}
}


hue定义好了JOB之后通过 ${fileName}来接受Oozie传的变量。 检查  workflow.xml文件的变量是否为${fileName}

来自 “ ITPUB博客 ” ,链接:https://blog.itpub.net/17036462/viewspace-2140444/ ,如需转载,请注明出处,否则将追究法律责任。

上一篇: Spark读HBASE
请登录后发表评论 登录
全部评论

注册时间:2011-05-19

  • 博文量
    15
  • 访问量
    14121