我正在寻找一种干净的方法来实现挂钩到 Hadoop v2 的 java 事件系统。我知道有一个通知网址，我过去曾使用过它。我想要做的是挂钩 JobStatus 并将事件发布到队列服务以将事件传播到客户端。我尝试扩展工作并使用反射将状态分配给我的自定义 JobStatus 类，但这不起作用。我还粗略地查看了 Yarn 的事件系统，以添加一个钩子，让我可以监听纱线事件并传播这些事件。我真的需要关于如何完成此类任务的专家意见。我想将日志消息、状态更改事件实时发送到 Web 客户端。
感谢您提前提供任何帮助。