如何编译和执行新的apachestorm调度程序代码?

zengzsys  于 2021-06-24  发布在  Storm
关注(0)|答案(1)|浏览(491)

我已经修改了apachestorm中现有的甚至调度程序代码。稍后如何在基准程序上编译和执行这个调度程序,并检查度量是否有任何更改?必须更改哪些配置文件?请提供一些有用的文件,并逐步解释。

mkshixfv

mkshixfv1#

这里有一篇循序渐进的文章https://inside.edited.com/taking-control-of-your-apache-storm-cluster-with-tag-aware-scheduling-b60aaaa5e37e.
相关部分:
总结一下,我们还应该介绍一下这个类实际上是如何被storm使用的。为此,我们需要做两件事:
通过config命令storm使用我们的调度程序而不是它的默认调度程序。
将我们的类打包成一个.jar文件,并将其添加到$storm\u home/lib目录中,以便storm能够访问它。
所需的配置也非常简单;与标记调度元数据类似,我们只需将这一行添加到$storm\u home/conf/storm.yaml中(并确保nimbus进程重新启动):
storm.scheduler:com.edited.tagawarescheduler.tagawarescheduler

相关问题