Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Storm 3544 Ability to find topologies with low worker uptime on UI #3172

Closed
wants to merge 2 commits into from
Closed

Storm 3544 Ability to find topologies with low worker uptime on UI #3172

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
2509e93
YSTORM-6952 Ability to find topologies with low worker uptime on UI. …
dandsager1 Nov 20, 2019
be8bfe6
non-thrift changes
dandsager1 Nov 20, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
288 changes: 144 additions & 144 deletions storm-client/src/jvm/org/apache/storm/generated/Assignment.java
View file
Open in desktop

Large diffs are not rendered by default.

340 changes: 170 additions & 170 deletions storm-client/src/jvm/org/apache/storm/generated/BoltStats.java
View file
Open in desktop

Large diffs are not rendered by default.

444 changes: 444 additions & 0 deletions storm-client/src/jvm/org/apache/storm/generated/ClusterTopologyOverview.java
View file
Open in desktop

Large diffs are not rendered by default.

52 changes: 26 additions & 26 deletions storm-client/src/jvm/org/apache/storm/generated/ClusterWorkerHeartbeat.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -605,17 +605,17 @@ public void read(org.apache.storm.thrift.protocol.TProtocol iprot, ClusterWorker
case 2: // EXECUTOR_STATS
if (schemeField.type == org.apache.storm.thrift.protocol.TType.MAP) {
{
org.apache.storm.thrift.protocol.TMap _map772 = iprot.readMapBegin();
struct.executor_stats = new java.util.HashMap<ExecutorInfo,ExecutorStats>(2*_map772.size);
@org.apache.storm.thrift.annotation.Nullable ExecutorInfo _key773;
@org.apache.storm.thrift.annotation.Nullable ExecutorStats _val774;
for (int _i775 = 0; _i775 < _map772.size; ++_i775)
org.apache.storm.thrift.protocol.TMap _map780 = iprot.readMapBegin();
struct.executor_stats = new java.util.HashMap<ExecutorInfo,ExecutorStats>(2*_map780.size);
@org.apache.storm.thrift.annotation.Nullable ExecutorInfo _key781;
@org.apache.storm.thrift.annotation.Nullable ExecutorStats _val782;
for (int _i783 = 0; _i783 < _map780.size; ++_i783)
{
_key773 = new ExecutorInfo();
_key773.read(iprot);
_val774 = new ExecutorStats();
_val774.read(iprot);
struct.executor_stats.put(_key773, _val774);
_key781 = new ExecutorInfo();
_key781.read(iprot);
_val782 = new ExecutorStats();
_val782.read(iprot);
struct.executor_stats.put(_key781, _val782);
}
iprot.readMapEnd();
}
Expand Down Expand Up @@ -662,10 +662,10 @@ public void write(org.apache.storm.thrift.protocol.TProtocol oprot, ClusterWorke
oprot.writeFieldBegin(EXECUTOR_STATS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.storm.thrift.protocol.TMap(org.apache.storm.thrift.protocol.TType.STRUCT, org.apache.storm.thrift.protocol.TType.STRUCT, struct.executor_stats.size()));
for (java.util.Map.Entry<ExecutorInfo, ExecutorStats> _iter776 : struct.executor_stats.entrySet())
for (java.util.Map.Entry<ExecutorInfo, ExecutorStats> _iter784 : struct.executor_stats.entrySet())
{
_iter776.getKey().write(oprot);
_iter776.getValue().write(oprot);
_iter784.getKey().write(oprot);
_iter784.getValue().write(oprot);
}
oprot.writeMapEnd();
}
Expand Down Expand Up @@ -697,10 +697,10 @@ public void write(org.apache.storm.thrift.protocol.TProtocol prot, ClusterWorker
oprot.writeString(struct.storm_id);
{
oprot.writeI32(struct.executor_stats.size());
for (java.util.Map.Entry<ExecutorInfo, ExecutorStats> _iter777 : struct.executor_stats.entrySet())
for (java.util.Map.Entry<ExecutorInfo, ExecutorStats> _iter785 : struct.executor_stats.entrySet())
{
_iter777.getKey().write(oprot);
_iter777.getValue().write(oprot);
_iter785.getKey().write(oprot);
_iter785.getValue().write(oprot);
}
}
oprot.writeI32(struct.time_secs);
Expand All @@ -713,17 +713,17 @@ public void read(org.apache.storm.thrift.protocol.TProtocol prot, ClusterWorkerH
struct.storm_id = iprot.readString();
struct.set_storm_id_isSet(true);
{
org.apache.storm.thrift.protocol.TMap _map778 = new org.apache.storm.thrift.protocol.TMap(org.apache.storm.thrift.protocol.TType.STRUCT, org.apache.storm.thrift.protocol.TType.STRUCT, iprot.readI32());
struct.executor_stats = new java.util.HashMap<ExecutorInfo,ExecutorStats>(2*_map778.size);
@org.apache.storm.thrift.annotation.Nullable ExecutorInfo _key779;
@org.apache.storm.thrift.annotation.Nullable ExecutorStats _val780;
for (int _i781 = 0; _i781 < _map778.size; ++_i781)
org.apache.storm.thrift.protocol.TMap _map786 = new org.apache.storm.thrift.protocol.TMap(org.apache.storm.thrift.protocol.TType.STRUCT, org.apache.storm.thrift.protocol.TType.STRUCT, iprot.readI32());
struct.executor_stats = new java.util.HashMap<ExecutorInfo,ExecutorStats>(2*_map786.size);
@org.apache.storm.thrift.annotation.Nullable ExecutorInfo _key787;
@org.apache.storm.thrift.annotation.Nullable ExecutorStats _val788;
for (int _i789 = 0; _i789 < _map786.size; ++_i789)
{
_key779 = new ExecutorInfo();
_key779.read(iprot);
_val780 = new ExecutorStats();
_val780.read(iprot);
struct.executor_stats.put(_key779, _val780);
_key787 = new ExecutorInfo();
_key787.read(iprot);
_val788 = new ExecutorStats();
_val788.read(iprot);
struct.executor_stats.put(_key787, _val788);
}
}
struct.set_executor_stats_isSet(true);
Expand Down
44 changes: 22 additions & 22 deletions storm-client/src/jvm/org/apache/storm/generated/CommonAggregateStats.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -835,15 +835,15 @@ public void read(org.apache.storm.thrift.protocol.TProtocol iprot, CommonAggrega
case 7: // RESOURCES_MAP
if (schemeField.type == org.apache.storm.thrift.protocol.TType.MAP) {
{
org.apache.storm.thrift.protocol.TMap _map396 = iprot.readMapBegin();
struct.resources_map = new java.util.HashMap<java.lang.String,java.lang.Double>(2*_map396.size);
@org.apache.storm.thrift.annotation.Nullable java.lang.String _key397;
double _val398;
for (int _i399 = 0; _i399 < _map396.size; ++_i399)
org.apache.storm.thrift.protocol.TMap _map404 = iprot.readMapBegin();
struct.resources_map = new java.util.HashMap<java.lang.String,java.lang.Double>(2*_map404.size);
@org.apache.storm.thrift.annotation.Nullable java.lang.String _key405;
double _val406;
for (int _i407 = 0; _i407 < _map404.size; ++_i407)
{
_key397 = iprot.readString();
_val398 = iprot.readDouble();
struct.resources_map.put(_key397, _val398);
_key405 = iprot.readString();
_val406 = iprot.readDouble();
struct.resources_map.put(_key405, _val406);
}
iprot.readMapEnd();
}
Expand Down Expand Up @@ -900,10 +900,10 @@ public void write(org.apache.storm.thrift.protocol.TProtocol oprot, CommonAggreg
oprot.writeFieldBegin(RESOURCES_MAP_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.storm.thrift.protocol.TMap(org.apache.storm.thrift.protocol.TType.STRING, org.apache.storm.thrift.protocol.TType.DOUBLE, struct.resources_map.size()));
for (java.util.Map.Entry<java.lang.String, java.lang.Double> _iter400 : struct.resources_map.entrySet())
for (java.util.Map.Entry<java.lang.String, java.lang.Double> _iter408 : struct.resources_map.entrySet())
{
oprot.writeString(_iter400.getKey());
oprot.writeDouble(_iter400.getValue());
oprot.writeString(_iter408.getKey());
oprot.writeDouble(_iter408.getValue());
}
oprot.writeMapEnd();
}
Expand Down Expand Up @@ -971,10 +971,10 @@ public void write(org.apache.storm.thrift.protocol.TProtocol prot, CommonAggrega
if (struct.is_set_resources_map()) {
{
oprot.writeI32(struct.resources_map.size());
for (java.util.Map.Entry<java.lang.String, java.lang.Double> _iter401 : struct.resources_map.entrySet())
for (java.util.Map.Entry<java.lang.String, java.lang.Double> _iter409 : struct.resources_map.entrySet())
{
oprot.writeString(_iter401.getKey());
oprot.writeDouble(_iter401.getValue());
oprot.writeString(_iter409.getKey());
oprot.writeDouble(_iter409.getValue());
}
}
}
Expand Down Expand Up @@ -1010,15 +1010,15 @@ public void read(org.apache.storm.thrift.protocol.TProtocol prot, CommonAggregat
}
if (incoming.get(6)) {
{
org.apache.storm.thrift.protocol.TMap _map402 = new org.apache.storm.thrift.protocol.TMap(org.apache.storm.thrift.protocol.TType.STRING, org.apache.storm.thrift.protocol.TType.DOUBLE, iprot.readI32());
struct.resources_map = new java.util.HashMap<java.lang.String,java.lang.Double>(2*_map402.size);
@org.apache.storm.thrift.annotation.Nullable java.lang.String _key403;
double _val404;
for (int _i405 = 0; _i405 < _map402.size; ++_i405)
org.apache.storm.thrift.protocol.TMap _map410 = new org.apache.storm.thrift.protocol.TMap(org.apache.storm.thrift.protocol.TType.STRING, org.apache.storm.thrift.protocol.TType.DOUBLE, iprot.readI32());
struct.resources_map = new java.util.HashMap<java.lang.String,java.lang.Double>(2*_map410.size);
@org.apache.storm.thrift.annotation.Nullable java.lang.String _key411;
double _val412;
for (int _i413 = 0; _i413 < _map410.size; ++_i413)
{
_key403 = iprot.readString();
_val404 = iprot.readDouble();
struct.resources_map.put(_key403, _val404);
_key411 = iprot.readString();
_val412 = iprot.readDouble();
struct.resources_map.put(_key411, _val412);
}
}
struct.set_resources_map_isSet(true);
Expand Down
Loading