storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [1/2] storm git commit: [STORM-3196] Add "owner" column to "storm list" output
Date Mon, 20 Aug 2018 05:12:54 GMT
Repository: storm
Updated Branches:
  refs/heads/master 88d19b098 -> 2875c838a


[STORM-3196] Add "owner" column to "storm list" output


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/5aff4658
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/5aff4658
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/5aff4658

Branch: refs/heads/master
Commit: 5aff46584b8ee22fa8e80ef47f9cc385e5f11e14
Parents: 4c42ee3
Author: Jacob Tolar <jtolar@oath.com>
Authored: Wed Aug 15 16:46:10 2018 -0500
Committer: Jacob Tolar <jtolar@oath.com>
Committed: Wed Aug 15 16:46:10 2018 -0500

----------------------------------------------------------------------
 .../src/jvm/org/apache/storm/command/ListTopologies.java      | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/5aff4658/storm-core/src/jvm/org/apache/storm/command/ListTopologies.java
----------------------------------------------------------------------
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 4fe2982..13d9691 100644
--- a/storm-core/src/jvm/org/apache/storm/command/ListTopologies.java
+++ b/storm-core/src/jvm/org/apache/storm/command/ListTopologies.java
@@ -21,7 +21,7 @@ import org.slf4j.LoggerFactory;
 
 public class ListTopologies {
     private static final Logger LOG = LoggerFactory.getLogger(ListTopologies.class);
-    private static final String MSG_FORMAT = "%-20s %-10s %-10s %-12s %-12s %-20s\n";
+    private static final String MSG_FORMAT = "%-20s %-10s %-10s %-12s %-12s %-20s %-20s\n";
 
     public static void main(String[] args) throws Exception {
         NimbusClient.withConfiguredClient(new NimbusClient.WithNimbus() {
@@ -31,12 +31,13 @@ public class ListTopologies {
                 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", "Topology_Id");
+                    System.out.printf(MSG_FORMAT, "Topology_name", "Status", "Num_tasks",
"Num_workers", "Uptime_secs", "Topology_Id", "Owner");
                     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_id());
+                                          topology.get_uptime_secs(), topology.get_id(),
+                                          topology.get_owner());
                     }
                 }
             }


Mime
View raw message