我正试图为apachehadoop dsl插件做一个开源贡献。基本上，我正在创建一个新的job类（我们称之为xyzjob）来扩展job，我需要一种方法来跟踪xyzjob过程中经过的时间。一旦过了一定的时间，我需要强制另一个动作，但我想不出正确跟踪时间的方法。mapred.task.timeout不起作用，因为它将强制终止作业，而不是让我强制执行其他操作。有什么想法/建议吗？