Каждый раз, когда я запускаю задание Hadoop внутри моего основного метода, единственное, что он делает, — это завершает задание. Например, скажем, у меня есть этот основной метод:
public static void main(String[] args)
{
System.out.println("before");
//code for creating job
//run job
System.out.println("after");
}
Сначала я мог только запустить задание, и ни одно из этих сообщений не появлялось. Я попытался запустить задание через отдельный поток, но единственное, чего я добился, - это появление обоих сообщений до того, как мое задание будет отправлено и завершено. Есть ли способ распечатать «до», выполнить задание, а затем распечатать «после»??
Это фиктивный пример. Что я действительно хочу сделать, так это запускать задания в цикле while (true), иметь некоторые условия внутри и запускать другие задания на основе этих условий, пока не появится перерыв. Я думаю, что те две проблемы, которые я упомянул, в некотором роде похожи, поэтому, решив фиктивный пример, я думаю, что смогу решить свою настоящую проблему.
Я не ищу что-то вроде Oozie, потому что уверен, что есть более простой способ сделать это. Спасибо.
