文档章节

Azkaban的线程系列 38:ExecutorManagerUpdaterThread

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

粉丝 864
博文 995
码字总数 676285
作品 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

没有更多内容

加载失败,请刷新页面

加载更多

创建第一个react项目

sudo npm i -g create-react-app@1.5.2 create-react-app react-app cd react-apprm -rf package-lock.jsonrm -rf node_modules #主要是为了避免报错npm installnpm start......

lilugirl
今天
1
0
在浏览器中进行深度学习:TensorFlow.js (八)生成对抗网络 (GAN)

Generative Adversarial Network 是深度学习中非常有趣的一种方法。GAN最早源自Ian Goodfellow的这篇论文。LeCun对GAN给出了极高的评价: “There are many interesting recent development...

naughty
今天
0
0
搬瓦工镜像站bwh1.net被DNS污染,国内打不开搬瓦工官网

今天下午(2018年10月17日),继搬瓦工主域名bandwagonhost.com被污染后,这个国内的镜像地址bwh1.net也被墙了。那么目前应该怎么访问搬瓦工官网呢? 消息来源:搬瓦工优惠网->搬瓦工镜像站b...

flyzy2005
今天
6
0
SpringBoot自动配置

本篇介绍下,如何通过springboot的自动配置,将公司项目内的依赖jar,不需要扫描路径,依赖jar的情况下,就能将jar内配置了@configuration注解的类,创建到IOC里面 介绍下开发环境 JDK版本1.8 spr...

贺小五
今天
5
0
命令行新建Maven多项目

参考地址 # DgroupId 可以理解为包名# DartifactId 可以理解为项目名mvn archetype:generate -DgroupId=cn.modfun -DartifactId=scaffold -DarchetypeArtifactId=maven-archetype-quickst......

阿白
今天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部