You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@storm.apache.org by "Robert Joseph Evans (JIRA)" <ji...@apache.org> on 2016/08/15 13:22:20 UTC

[jira] [Commented] (STORM-1985) Provide a tool for showing and killing corrupted topology

    [ https://issues.apache.org/jira/browse/STORM-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420963#comment-15420963 ] 

Robert Joseph Evans commented on STORM-1985:
--------------------------------------------

It was asked on the mailing list where this code should live.  This was my answer.

bq. My guess is that this is going to be a new tool.  I think we want to start looking into supporting a storm admin tool that will give users that have access to super user credentials access to directly examine/modify the state of a running storm cluster, zookeeper, blobstore, and local state. I don't expect you to do all of that work, but at least starting a place for a storm admin command in my opinion is the best place for this.

> Provide a tool for showing and killing corrupted topology
> ---------------------------------------------------------
>
>                 Key: STORM-1985
>                 URL: https://issues.apache.org/jira/browse/STORM-1985
>             Project: Apache Storm
>          Issue Type: Bug
>          Components: storm-core
>            Reporter: Jungtaek Lim
>              Labels: newbie
>
> After STORM-1976, Nimbus doesn't clean up corrupted topologies.
> (corrupted topology means the topology whose codes are not available on blobstore.)
> Also after STORM-1977, no Nimbus is gaining leadership if one or more topologies are corrupted, which means all nimbuses will be no-op.
> So we should provide a tool to kill specific topology without accessing leader nimbus (because there's no leader nimbus at that time). The tool should also determine which topologies are corrupted, and show its list or clean up automatically.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)