Github user d2r commented on a diff in the pull request:
https://github.com/apache/storm/pull/2878#discussion_r225581522
--- Diff: storm-core/src/jvm/org/apache/storm/command/KillTopology.java ---
@@ -25,21 +25,49 @@
public static void main(String[] args) throws Exception {
Map<String, Object> cl = CLI.opt("w", "wait", null, CLI.AS_INT)
+ .boolOpt("i", "ignore-errors")
.arg("TOPO", CLI.INTO_LIST)
.parse(args);
+
+ @SuppressWarnings("unchecked")
final List<String> names = (List<String>) cl.get("TOPO");
+
+ // wait seconds for topology to shut down
--- End diff --
Maybe `Wait this many seconds after deactivating topology before killing`?
---
