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 2017/09/04 05:22:47 UTC
[1/2] storm git commit: [STORM-2717] Output topology Id from storm
list command
Repository: storm
Updated Branches:
refs/heads/master aefc72520 -> a9f92dba0
[STORM-2717] Output topology Id from storm list command
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/9565b003
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/9565b003
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/9565b003
Branch: refs/heads/master
Commit: 9565b003f206d7a10927f315158bf3633c4eef29
Parents: 758a1d2
Author: Ethan Li <et...@gmail.com>
Authored: Fri Sep 1 21:56:44 2017 +0000
Committer: Ethan Li <et...@gmail.com>
Committed: Fri Sep 1 21:56:44 2017 +0000
----------------------------------------------------------------------
.../src/jvm/org/apache/storm/command/ListTopologies.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/9565b003/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 231ca0f..20d5b6f 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 @@ import java.util.List;
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 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");
- 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());
}
}
}
[2/2] storm git commit: Merge branch 'STORM-2717' of
https://github.com/Ethanlm/storm into STORM-2717
Posted by ka...@apache.org.
Merge branch 'STORM-2717' of https://github.com/Ethanlm/storm into STORM-2717
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/a9f92dba
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/a9f92dba
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/a9f92dba
Branch: refs/heads/master
Commit: a9f92dba040d41974d144e1340a161b38752d382
Parents: aefc725 9565b00
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Mon Sep 4 14:22:31 2017 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Mon Sep 4 14:22:31 2017 +0900
----------------------------------------------------------------------
.../src/jvm/org/apache/storm/command/ListTopologies.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------