时间戳

首页 > 解决方案 > 如何编译和执行新的 apache Storm 调度程序代码？

java - 如何编译和执行新的 apache Storm 调度程序代码？

问题描述

我已经修改了 Apache Storm 中现有的 Even Scheduler 代码。稍后我如何在基准程序上编译和执行这个调度程序并检查指标是否有任何变化？需要更改哪些配置文件？请提供一些有帮助的文档，并提供分步说明。

标签： javacompilationschedulerapache-stormexecute

解决方案

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

相关部分：

总结一下，我们还应该介绍 Storm 实际使用该类的方式。为此，我们需要做两件事：

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

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

storm.scheduler：com.edited.tagawarescheduler.TagAwareScheduler

推荐阅读