You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2018/08/20 05:12:54 UTC
[1/2] storm git commit: [STORM-3196] Add "owner" column to "storm
list" output
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 <jt...@oath.com>
Authored: Wed Aug 15 16:46:10 2018 -0500
Committer: Jacob Tolar <jt...@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());
}
}
}
[2/2] storm git commit: Merge branch 'STORM-3196' of
https://github.com/jacobtolar/storm into STORM-3196-merge
Posted by ka...@apache.org.
Merge branch 'STORM-3196' of https://github.com/jacobtolar/storm into STORM-3196-merge
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/2875c838
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/2875c838
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/2875c838
Branch: refs/heads/master
Commit: 2875c838a9577ca81e119de6601a0f5d0184b663
Parents: 88d19b0 5aff465
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Mon Aug 20 14:12:26 2018 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Mon Aug 20 14:12:26 2018 +0900
----------------------------------------------------------------------
.../src/jvm/org/apache/storm/command/ListTopologies.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------