Killing a task manually in Apache Storm

Question

For testing / debugging, is there an easy way to manually kill a task in a storm cluster? It would be best to turn it on from the storm. Even if the storm should reassign failed tasks, it would be nice to check our code when that happens.

Of course, I can add a "throw RuntimeException" to the code in some conditions to do this, but it needs manual coding, maybe there is a function in the storm architecture for this function?

Answer 1

Tasks are logical units of work that are processed as performers. Executors are threads within a working JVM. Thus, the only way to kill one task manually (via kill on the command line) is to set the number of tasks equal to the number of performers (which is the default) and provide more workers than performers (for example, #workers> amount (additional of each tray / bolt ). The presence of a larger number of employees than the executors ensures that one executor is launched for each employee.