java - 如何从 Java 中停止 Hadoop 作业

Question

我有一个由 8 台机器组成的服务器设置，我在这些机器上运行 Hadoop 作业来下载某些 Assets 。客户端代理使用 JobConf 启动 Hadoop 作业。

代理从服务器获取响应代码，根据该代码可以确定下载的进行方式。在下面的代码中，invoke() 创建到服务器公开的 REST API 的连接。 ResponseData 是一个自定义类，可以从与响应关联的连接中读取下载的数据，如下所示:

ResponseData res = invoke(downloadUrl, contentType);
downloadedAssetStream = New ObjectInputStream(res.connection.getInputStream);

if(res.code != 200)
{
    //Stop hadoop job
}

要停止工作，我需要什么？我在某处听说抛出 IOException 可以，但我还无法验证它。

Answer 1

Job#killJob使用新的 MR API 或 RunningJob#killJob使用旧的 MR API 会终止作业。