Loading [MathJax]/jax/output/CommonHTML/config.js
前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >专栏 >通过oozieClient获取指定jobid工作流的状态信息以及节点的状态信息

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

作者头像
用户1171305
发布于 2019-07-02 02:11:43
发布于 2019-07-02 02:11:43
9460
举报
文章被收录于专栏:成长道路成长道路

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.结果截图

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2018年12月03日,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
暂无评论
推荐阅读
编辑精选文章
换一批
如何使用Oozie API接口向非Kerberos环境的CDH集群提交Shell工作流
前面Fayson介绍了《如何使用Oozie API接口向非Kerberos环境的CDH集群提交Spark作业》和《如何使用Oozie API接口向非Kerberos环境的CDH集群提交Java作业》,本篇文章主要介绍如何使用Oozie Client API向非Kerberos环境的CDH集群提交Shell Action工作流。
Fayson
2018/03/30
1.1K0
如何使用Oozie API接口向非Kerberos环境的CDH集群提交Java作业
前面Fayson介绍了《如何使用Oozie API接口向非Kerberos环境的CDH集群提交Spark作业》,本篇文章主要介绍如何使用Oozie Client API向非Kerberos环境的CDH集群提交Java作业。
Fayson
2018/03/30
1.1K0
如何使用Oozie API接口向Kerberos环境的CDH集群提交Spark作业
在CDH集群外的节点向集群提交Spark作业的方式有多种,前面Fayson介绍了Livy相关的文章主要描述如何在集群外节点通过RESTful API接口向CDH集群提交Spark作业以及《如何使用Oozie API接口向非Kerberos环境的CDH集群提交Spark作业》,本篇文章主要介绍使用Oozie的API接口向Kerberos集群提交Spark作业。
Fayson
2018/03/29
2K0
如何使用Oozie API接口向Kerberos环境的CDH集群提交Shell作业
前面Fayson介绍了使用Oozie API向Kerberos和非Kerberos集群提交Spark和Java作业,本篇文章主要介绍如何使用Oozie Client API向Kerberos环境的CDH集群提交Shell Action工作流。
Fayson
2018/03/30
1.7K0
如何使用Oozie API接口向Kerberos环境的CDH集群提交Spark2作业
前面Fayson介绍了多种方式在CDH集群外的节点向集群提交Spark作业,文章中均采用Spark1来做为示例,本篇文章主要介绍如何是用Oozie API向Kerberos环境的CDH集群提交Spark2作业。
Fayson
2018/03/30
3.4K0
Oozie工作流分析
我们在实际的生成操作中经常需要将一些任务在晚上开启进行定时执行,或者多个作业,例如hive,mapreduce,shell等任务的组合调用。
Tim在路上
2020/08/04
1.2K0
如何使用Oozie API接口向非Kerberos环境的CDH集群提交Spark作业
在CDH集群外的节点向集群提交Spark作业的方式有多种,前面Fayson介绍了Livy相关的文章主要描述如何在集群外节点通过RESTful API接口向CDH集群提交Spark作业,本篇文章我们借助于oozie-client的API接口向非Kerberos集群提交Spark作业。
Fayson
2018/03/30
1.5K0
如何使用Oozie API接口向Kerberos集群提交Java程序
在CDH集群外的节点向集群提交MapReduce作业的方式有多种,前面Fayson介绍了《如何跨平台在本地开发环境提交MapReduce作业到CDH集群》和《如何使用Oozie API接口向非Kerberos环境的CDH集群提交Java作业》,本篇文章主要介绍如何在Kerberos集群使用Oozie API接口向集群提交Java作业。
Fayson
2018/03/30
2.6K0
Httpclient 调用 HTTPS 加密通道的Restful服务
为 Restful 增加 SSL 证书,保证数据在传输中安全。 证书有两类,一类是授信办颁发构的证书,另一类是自己创建的证书,两种证书使用效果上一样。 授信证书的跟证书默认已经安装在操作系统,浏览器中,访问时会出现锁头跟绿色标识。这种证书是需要购买的,因为这些证书厂商每年都要像微软,苹果等等操作系统厂商支付一定费用。 最近火狐公司发表声明,将取消“沃通”根证书,这就意味着这所有沃通用户都会变成 红叉叉。 对于内部业务不需要对外提供服务,例如Restful 服务,我见意自己创建证书,如果你需要让浏览器地址栏变
netkiller old
2018/03/05
3.1K0
项目管理Maven系列(四)- 结合Selenium、Appium、OkHttp、HttpClient
5、执行脚本(pom.xml鼠标右键Run As--->Maven test即可)。
wangmcn
2022/07/25
2.6K0
项目管理Maven系列(四)- 结合Selenium、Appium、OkHttp、HttpClient
json字符串转换为Json对象_前端字符串转json
参考网上的文章,做了一个关于json的总结,进行留存帮助以后阅读,希望可以帮助到大家。
全栈程序员站长
2022/09/28
8.2K0
SpringMVC 连接Redis数据库
1、pom.xml <!-- redis --> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <scope>compile</scope> </dependency> 2、测试类 /** * */ package cn.bizbook.resource.manage.dao.impl; import static o
week
2018/08/27
4890
Curator实现基于zookeeper leader选举
Curator Framework是一个针对zookeeper做的搞层次的API,极大地简化了zookeeper的使用。它基于zookeeper构建了很多功能,处理复杂的链接管理,重试操作。下面是它的一些特点:
Spark学习技巧
2020/04/24
9280
基于zookeeper leader选举方式一
一,基本介绍 Curator Framework是一个针对zookeeper做的搞层次的API,极大地简化了zookeeper的使用。它基于zookeeper构建了很多功能,处理复杂的链接管理,重试操作。下面是它的一些特点: 1,自动连接管理。 A),存在的潜在错误情况,需要ZooKeeper客户端创建连接和/或重试操作。Curator 自动和透明(主要)处理这些情况。 B),监视NodeDataChanged事件,并根据需要调用updateServerList()。 C),Watches 会被Curato
Spark学习技巧
2018/01/30
1.2K0
基于zookeeper leader选举方式一
用Java来开发Hive应用
在hive配置文件:%HIVE_HOME%/conf/hive-site.xml添加
顾翔
2024/09/10
910
用Java来开发Hive应用
打工人打工魂,打工的必会java调用python的几种用法(看这篇就够了)
创建maven工程,结构如下:到官网https://www.jython.org/download.html下载Jython的jar包或者在maven的pom.xml文件中加入如下代码:
用户7656790
2020/11/03
5.9K0
打工人打工魂,打工的必会java调用python的几种用法(看这篇就够了)
结合Spring发送邮件的四种正确姿势,你知道几种?
测试使用的环境是企业主流的SSM 框架即 SpringMVC+Spring+Mybatis。为了节省时间,我直接使用的是我上次的“SSM项目中整合Echarts开发”该项目已经搭建完成的SSM环境。
用户2164320
2018/08/10
8880
结合Spring发送邮件的四种正确姿势,你知道几种?
Canal连接kafka实现实时同步mysql数据
canal-kafka是阿里云最近更新的一个新的安装包。主要功能是实现canal与kafka的对接,实现海量的消息传输同步。在canal-kafka中,消息是以ByteString进行传输的,并且用户只能通过配置来指定一些kafka的配置,从某种程度上有一定的局限性,所以我们使用canal来自定义客户端kafka,会有更好的灵活性,但维护成本会更大,所以如何选择根据实际情况而定。
王知无-import_bigdata
2019/10/15
2.8K0
Java实现微信跳一跳抓包修改分数
原改分代码为Python代码, import requests import json import time from Crypto.Cipher import AES import base64 action_data = { "score": 10086, "times": 666, "game_data": "{}" } session_id = "5TrXoE7IXtM/Nr7vITnbU9bmR53VH0u8RkVnm6m/Fezg==" aes_key = ses
杨逸轩
2018/06/14
1.4K0
生成订单30分钟未支付,则自动取消,该怎么实现?
对上述的任务,我们给一个专业的名字来形容,那就是延时任务。那么这里就会产生一个问题,这个延时任务和定时任务的区别究竟在哪里呢?一共有如下几点区别
良月柒
2021/09/03
6480
推荐阅读
相关推荐
如何使用Oozie API接口向非Kerberos环境的CDH集群提交Shell工作流
更多 >
领券
💥开发者 MCP广场重磅上线!
精选全网热门MCP server,让你的AI更好用 🚀
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档