通过oozieClient获取指定jobid工作流的状态信息以及节点的状态信息

2019-07-02 10:11:43 浏览数 (2)

1.pom文件添加依赖

<dependency> <groupId>org.apache.oozie</groupId> <artifactId>oozie-client</artifactId> <version>4.3.1</version> </dependency>

2.java代码

OozieClient wc = new OozieClient("http://192.168.84.27:11000//oozie"); Properties conf = wc.createConfiguration(); try { String status = wc.getStatus("0000788-181029001659216-oozie-oozi-W"); List<WorkflowAction> workflowActions = wc.getJobInfo("0000788-181029001659216-oozie-oozi-W").getActions(); System.out.println(status); for(WorkflowAction workflowAction : workflowActions){ System.out.println(workflowAction.getName()); System.out.println(workflowAction.getStatus()); } } catch (OozieClientException e) { // TODO Auto-generated catch block e.printStackTrace(); }

3.结果截图

es2

0 人点赞