我已经修改了apachestorm中现有的甚至调度程序代码。稍后如何在基准程序上编译和执行这个调度程序,并检查度量是否有任何更改?必须更改哪些配置文件?请提供一些有用的文件,并逐步解释。
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
1条答案
按热度按时间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