apache-storm – 在Apache Storm中手动杀死任务

出于测试/调试目的,是否有一种简单的方法可以手动终止风暴群集中的任务?最好的方法是从风暴ui启用它.即使风暴应该重新分配失败的任务,最好在它发生时测试我们的代码.

当然我可以在某些条件下在代码中添加’throw RuntimeException’,但它需要手动编码,也许风暴架构中有一个函数?

最佳答案 任务是由执行者处理的逻辑工作单元.执行程序是工作程序JVM中的线程.因此,手动终止单个任务的唯一方法(通过命令行中的kill)将设置任务数量等于执行者数量(默认值是什么)并提供比执行者更多的工作者(即#workers&gt总和(每个喷嘴/螺栓的掺杂).拥有更多的工人而不是执行者确保在每个工人中运行一个执行器.

点赞