如何在Java中终止(或杀死)Hadoop作业

Question

假设我们有一个MapReduce作业，我们希望在Java MapReduce中执行该作业的终止/终止操作——比如在一段特定的时间之后，我该怎么做呢?

例如

，在指定的时间段后终止作业

Answer 1

您可以使用作业ID获取作业，然后使用Job.killJob()

Answer 2

您可以使用Thread.sleep()设置一个简单的计时器，然后使用job. killjob()来终止作业。