Azkaban的Web Server源碼探究系列25: 一次性執行execute任務實際分發過程

下面就講解如何把一個任務真正的分發到指定的executor上！！！

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

上節講到了在函數azkaban.executor.ExecutorManager.callExecutorServer中有這麼一行

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

進入這個函數一探究竟！

---

// 構造http client

ExecutorApiClient apiclient = ExecutorApiClient.getInstance();

@SuppressWarnings("unchecked")

// 構造URI

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!!!