如何记录来自 Hadoop Mapper(或 Combiner/Reducer/其他)的消息，以便稍后在 Hadoop 日志中找到这些自定义消息？
public class GfimlMapper extends Mapper<Object, Text, Text, RawTerm>
{
public void map(Object key, Text value, final Context context
) throws IOException, InterruptedException {
...
Logger.log("HELLO THERE!"); // ???
...
}
}
最佳答案
如果您转到集群的作业跟踪器，然后转到您的个人作业，您应该会得到已执行的任务(maps 和 reduce)列表，然后右侧应该有一个链接可以查看该任务的日志。然后你可以在那里看到 stdout、syserr 和系统日志。检查 stdout(不是所有的都有输出，但根据我的经验至少有一个输出...)
祝你好运!
关于java - 如何记录来自 Hadoop 的消息？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/7305015/