如何编译和执行新的apache风暴调度程序代码？

Question

我在Apache Storm中修改了现有的Even Scheduler代码。以后如何在基准程序上编译和执行此调度程序，并检查指标是否有任何变化？什么配置文件必须更改？请提供一些有用的文档，并逐步说明。

Answer 1

这里有一步一步的文章https://inside.edited.com/taking-control-of-your-apache-storm-cluster-with-tag-aware-scheduling-b60aaaa5e37e。

相关部分：

为了总结，我们还应该介绍Storm如何实际使用这个类。我们需要做两件事：

• 通过config，指示storm使用我们的调度程序而不是默认调度程序。
• 将我们的类打包在.jar文件中，并将其添加到$ STORM_HOME / lib目录中，以便Storm能够访问它。

必要的配置也很简单;与标签调度元数据类似，我们只需将此行添加到$ STORM_HOME / conf / storm.yaml（并确保重新启动nimbus进程）：

storm.scheduler：com.edited.tagawarescheduler.TagAwareScheduler