From 9565b003f206d7a10927f315158bf3633c4eef29 Mon Sep 17 00:00:00 2001 From: Ethan Li Date: Fri, 1 Sep 2017 21:56:44 +0000 Subject: [PATCH] [STORM-2717] Output topology Id from storm list command --- .../src/jvm/org/apache/storm/command/ListTopologies.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/storm-core/src/jvm/org/apache/storm/command/ListTopologies.java b/storm-core/src/jvm/org/apache/storm/command/ListTopologies.java index 231ca0f3bdd..20d5b6fc3e1 100644 --- a/storm-core/src/jvm/org/apache/storm/command/ListTopologies.java +++ b/storm-core/src/jvm/org/apache/storm/command/ListTopologies.java @@ -28,7 +28,7 @@ public class ListTopologies { private static final Logger LOG = LoggerFactory.getLogger(ListTopologies.class); - private static final String MSG_FORMAT = "%-20s %-10s %-10s %-12s %-10s\n"; + private static final String MSG_FORMAT = "%-20s %-10s %-10s %-12s %-12s %-20s\n"; public static void main(String [] args) throws Exception { NimbusClient.withConfiguredClient(new NimbusClient.WithNimbus() { @@ -38,12 +38,12 @@ public void run(Nimbus.Iface nimbus) throws Exception { if (topologies == null || topologies.isEmpty()) { System.out.println("No topologies running."); } else { - System.out.printf(MSG_FORMAT, "Topology_name", "Status", "Num_tasks", "Num_workers", "Uptime_secs"); - System.out.println("-------------------------------------------------------------------"); + System.out.printf(MSG_FORMAT, "Topology_name", "Status", "Num_tasks", "Num_workers", "Uptime_secs", "Topology_Id"); + System.out.println("----------------------------------------------------------------------------------------"); for (TopologySummary topology: topologies) { System.out.printf(MSG_FORMAT, topology.get_name(), topology.get_status(), topology.get_num_tasks(), topology.get_num_workers(), - topology.get_uptime_secs()); + topology.get_uptime_secs(), topology.get_id()); } } }