文档章节

Azkaban的线程系列 38:ExecutorManagerUpdaterThread

强子哥哥
 强子哥哥
发布于 2016/04/13 16:36
字数 152
阅读 180
收藏 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()

 


© 著作权归作者所有

共有 人打赏支持
强子哥哥

强子哥哥

粉丝 861
博文 902
码字总数 616494
作品 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

没有更多内容

加载失败,请刷新页面

加载更多

下一页

谷歌 Fuchsia 上手体验,将取代Android/win10

在手机市场领域,Google表现很抢眼,毫无疑问,Android 至今在移动操作系统的市场份额占据绝对领先地位,但是 Android 仍然存在不少问题,碎片化问题严重,在平板以及大屏幕设备上表现糟糕,...

linux-tao
29分钟前
1
0
List、Array与ArrayList

数组在内存中是连续存储的,所以它的索引速度很快,而且赋值和修改元素也非常快,比如: string[] s=new string[3];//赋值 s[0]="a"; s[1]="b"; s[2]="c";//修改 s[1]="b1"; 但是数组...

shimmerkaiye
32分钟前
0
0
Linux 的Lnmp环境下为mysql添加环境变量

一.问题 在Linux 安装完Lnmp 环境后 , 连接Mysql 告诉没有这条命令 mysql -uroot -p 命令失效 因为是源码安装的,所以会出现这样的的原因 。集成环境是不会出现的。 其实很简单,只需要给m...

15834278076
34分钟前
3
0
apolloxlua include函数

include函数不是单独使用的函数, 他并不是标准库的一部分, 你可以使用include函数将某个后缀为 .aop的文档包含到你的文档流中。 因为include是单独处理流, 所以不会在主处理流程中有所表示...

钟元OSS
38分钟前
0
0
【转载分享】做一名较真的工程师

近些年与我共事过的同事,一定知道我至今仍有一个较真的性格。我会:指出同事所写代码的不当命名问题(并帮助改进);指出同事所写文档中的逻辑混乱问题(并辅以修订);指出同事所写PPT中乱...

HellerZhang
39分钟前
3
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部