Azkaban的Web Server源码探究系列25: 一次性执行execute任务实际分发过程

时间 2019-11-17

标签 azkaban web server 源码探究系列一次性执行 execute 任务实际分发过程栏目 HTML 繁體版

原文原文链接

下面就讲解如何把一个任务真正的分发到指定的executor上！！！json

=================================================================api

上节讲到了在函数azkaban.executor.ExecutorManager.callExecutorServer中有这么一行函数

Map<String, Object> jsonResponse = callExecutorForJsonObject(host, port, "/executor", paramList);ui

进入这个函数一探究竟！spa

---ci

// 构造http clientget

ExecutorApiClient apiclient = ExecutorApiClient.getInstance();io

@SuppressWarnings("unchecked")cli

// 构造URIList

URI uri = ExecutorApiClient.buildUri(host, port, path, true, paramList.toArray(new Pair[0]));

return apiclient.httpGet(uri, null);

---

具体产生的URL相似于：

uri = "http://x.x.x.x:port/executor?action=execute&execid=12&user"

因此先暂时告一段落，去启动executor!!!