文档章节

Azkaban的线程系列 38:ExecutorManagerUpdaterThread

强子1985
 强子1985
发布于 2016/04/13 16:36
字数 152
阅读 191
收藏 0

ExecutorManagerUpdaterThread线程如何运行?主要是获取

当前运行的flow的状态!

相关的几种操作有

public static final String UPDATE_ACTION = "update";

  public static final String STATUS_ACTION = "status";

  public static final String EXECUTE_ACTION = "execute";

  public static final String CANCEL_ACTION = "cancel";

  public static final String PAUSE_ACTION = "pause";

  public static final String RESUME_ACTION = "resume";

拿一个例子来说,如何pause?

public void pauseFlow(int execId, String user) throws ExecutorManagerException {

FlowRunner runner = runningFlows.get(execId);

 

if (runner == null) {

throw new ExecutorManagerException("Execution " + execId + " is not running.");

}

 runner.pause(user);

}

那么,flowRunner如何执行pause操作呢?

就是设置一个变量,然后不停循环查看变量的值

===================================================================================

关于如何取消一个任务见 

azkaban.jobExecutor.ProcessJob.cancel()

 


© 著作权归作者所有

共有 人打赏支持
强子1985

强子1985

粉丝 882
博文 1179
码字总数 870993
作品 8
南京
架构师
私信 提问
Azkaban的Exec Server分析 32:关于提醒邮件发送

本来也在琢磨,这个邮件发送的代码在哪,正好看到了下面的报错! ===================================================================================== 看来需要去管理这个线程 azkaba...

强子哥哥
2016/04/12
528
0
Azkaban的线程系列 37:QueueProcessor线程的任务处理&executor存活监控

有个线程,AzkabanWebServer-QueueProcessor-Thread. 下面分析下这个线程到底干嘛的!!! ==================================================================================== stop in......

强子哥哥
2016/04/13
286
0
Azkaban的Web Server源码探究系列24: 一次性执行execute任务取出处理

提交之后,很不幸,有个问题如下: 抓包分析: 请求和响应分别如下: 所以接下来需要对这个URL进行debug ============================================================================== ...

强子哥哥
2016/04/10
212
0
Azkaban的定时调度任务分析34:定时执行下文

下面说线程azkaban.trigger.TriggerManager.TriggerScannerThread是如何运作的 1)初始化 stop in azkaban.trigger.TriggerManager$TriggerScannerThread.xxx run 初始化的上下文是: java.l......

强子哥哥
2016/04/12
189
0
工作流调度器Azkaban的安装配置

Azkaban安装部署 准备工作 Azkaban Web服务器 azkaban-web-server-2.5.0.tar.gz Azkaban执行服务器 azkaban-executor-server-2.5.0.tar.gz MySQL 目前azkaban只支持 mysql,需安装mysql服务器......

ChinaUnicom110
2017/09/29
0
0

没有更多内容

加载失败,请刷新页面

加载更多

C#默认OrderBy()函数的排序问题

昨天在客户现场遇到一个很奇葩的问题,猜下下面代码的排序输出是什么: static void Main(){ List<string> strs = new List<string>(){"11", "12", "1:"}; foreach(string str i......

Airship
30分钟前
2
0
Vue调试神器Vue.js devtools

前言: Vue.js devtools是一个高效的vue项目可视化检查工具,其主要功能就是可以快速查看页面结构、组件中的data变量、computed计算属性、props父组件传过来的值等等 Chrome上的使用方法: 科学...

JamesView
35分钟前
14
0
最全面的IGMP协议总结!

IGMP互联网组管理协议是TCP/IP 协议族中负责IP组播成员管理的协议,用来在IP主机和与其直接相邻的组播路由器之间建立、维护组播组成员关系。 一、IGMP 简介 IGMP(Internet Group Management...

linuxprobe16
39分钟前
1
0
node-sass 安装失败的各种坑

开始的时候引入别人的一个项目 npm install npm run dev 启动项目 报错 > sell@1.0.0 dev E:\web_hwf\Vue\02app > node build/dev-server.js Listening at http://localhost:8888 webpack: w......

黑魔法
41分钟前
1
0
Qemu中PCI设备透传(PCI-Assign)源码分析

在网上看到很多人说Qemu的PCI-Assign透传不支持IOMMU,而VFIO透传却可以(还被当做一种优势进行推荐)。而VFIO跟SRIOV并非有必然联系,那就是说VFIO和PCI-Assign进本都是靠软件实现的了?既然...

LastRitter
43分钟前
8
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部