0
我已经找到this solution。但是,答案说这样做是不安全的,有没有更安全的方式来使用新的MapReduce库(org.apache.hadoop.mapreduce)如何在检查条件后终止mapreduce作业?
我已经找到this solution。但是,答案说这样做是不安全的,有没有更安全的方式来使用新的MapReduce库(org.apache.hadoop.mapreduce)如何在检查条件后终止mapreduce作业?
因为我愿意终止在循环中运行的MapReduce作业;所以,我解决了使用计数器如下这个问题,
public static enum SOLUTION_FLAG{
SOLUTION_FOUND;
}
我把帮助从这个网站,
How to use the counters in Hadoop?
从标志的值,我决定,如果我可以跳过任务,当一个工作结束时,在每个循环结束时,我检查这个标志的值。
让我知道,如果我做得对。