У меня есть настройка сервера, состоящая из 8 машин, на которых я запускаю задание Hadoop для загрузки определенных ресурсов. Агент на стороне клиента использует 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, но я пока не смог его проверить.