[jira] [Updated] (STORM-3687) Add a warning about possible issues on a mixed cluster if the StormCommon.systemTopology implementation is changed

2020-08-05 Thread Ethan Li (Jira)


 [ 
https://issues.apache.org/jira/browse/STORM-3687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ethan Li updated STORM-3687:

Issue Type: Comment  (was: Task)

> Add a warning about possible issues on a mixed cluster if the 
> StormCommon.systemTopology implementation is changed
> --
>
> Key: STORM-3687
> URL: https://issues.apache.org/jira/browse/STORM-3687
> Project: Apache Storm
>  Issue Type: Comment
>Reporter: Ethan Li
>Assignee: Ethan Li
>Priority: Minor
> Fix For: 2.3.0
>
>  Time Spent: 20m
>  Remaining Estimate: 0h
>
> During rolling upgrade, some supervisors are still at 2.2, and others are 
> running on 2.3. So some workers are running with storm-client-2.2.jar and 
> others are on 2.3.
> Because of 
> https://github.com/apache/storm/commit/93a7f770d508668bc7af183e08535813fff6f805
>  (STORM-3660)
> the "_credentials" stream is removed.
> So the map of streamId to streamName for system component is changed 
> refer to the code at:
> https://github.com/apache/storm/blob/v2.2.0/storm-client/src/jvm/org/apache/storm/serialization/SerializationFactory.java#L218-L222
> So a worker running on storm-client-2.2 might send out __metrics from its 
> systembolt, while the MetricsConsumer running with storm-client-2.3 
> interprets it as "__metrics_tick" because the mapping is different:
> {code:java}
> o.a.s.s.SerializationFactory Thread-15-__system-executor[-1, -1] [INFO] idmap 
> for system comp {__tick=6, __system=5, __metrics_tick=4, __credentials=1, 
> __flush=2, __metrics=3}
> {code}
> vs
> {code:java}
> o.a.s.s.SerializationFactory Netty-server-localhost-6703-worker-1 [INFO] 
> idmap for system comp {__tick=5, __system=4, __metrics_tick=3, __flush=1, 
> __metrics=2}
> {code}
> Hence we see
> {code:java}
> Caused by: java.lang.RuntimeException: java.lang.ClassCastException: 
> org.apache.storm.metric.api.IMetricsConsumer$TaskInfo cannot be cast to 
> java.lang.Integer
> at org.apache.storm.executor.Executor.accept(Executor.java:293) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:113) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consume(JCQueue.java:89) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:167) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:153) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$1.run(Utils.java:398) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> ... 1 more
> Caused by: java.lang.ClassCastException: 
> org.apache.storm.metric.api.IMetricsConsumer$TaskInfo cannot be cast to 
> java.lang.Integer
> at org.apache.storm.tuple.TupleImpl.getInteger(TupleImpl.java:121) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.executor.Executor.metricsTick(Executor.java:320) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor.tupleActionFn(BoltExecutor.java:213)
>  ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.executor.Executor.accept(Executor.java:286) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:113) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consume(JCQueue.java:89) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:167) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:153) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$1.run(Utils.java:398) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> ... 1 more
> 2020-08-04 18:26:08.017 o.a.s.m.c
> 2020-08-04 18:26:08.027 o.a.s.u.Utils 
> Thread-19-__metrics_org.apache.storm.metric.LoggingMetricsConsumer-executor[1555,
>  1555] [ERROR] Halting process: Worker died
> java.lang.RuntimeException: Halting process: Worker died
> at org.apache.storm.utils.Utils.exitProcess(Utils.java:518) 
> [storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$3.run(Utils.java:870) 
> [storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.error.ReportErrorAndDie.uncaughtException(ReportErrorAndDie.java:41)
>  [storm-client-2.3.0.y.jar:2.3.0.y]
> at java.lang.Thread.dispatchUncaughtException(Thread.java:1959) 
> [?:1.8.0_242]
> 2020-08-04 18:26:08.027 o.a.s.u.Utils 
> Thread-18-__metrics_org.apache.storm.metric.LoggingMetricsConsumer-executor[1553,
>  1553] [ERROR] Halting 

[jira] [Commented] (STORM-3687) Add a warning about possible issues on a mixed cluster if the StormCommon.systemTopology implementation is changed

2020-08-05 Thread Ethan Li (Jira)


[ 
https://issues.apache.org/jira/browse/STORM-3687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172024#comment-17172024
 ] 

Ethan Li commented on STORM-3687:
-

Merged to master (c9276d228426ba076e9a4690998ab9c4570e16f2)

> Add a warning about possible issues on a mixed cluster if the 
> StormCommon.systemTopology implementation is changed
> --
>
> Key: STORM-3687
> URL: https://issues.apache.org/jira/browse/STORM-3687
> Project: Apache Storm
>  Issue Type: Task
>Reporter: Ethan Li
>Priority: Minor
> Fix For: 2.3.0
>
>  Time Spent: 20m
>  Remaining Estimate: 0h
>
> During rolling upgrade, some supervisors are still at 2.2, and others are 
> running on 2.3. So some workers are running with storm-client-2.2.jar and 
> others are on 2.3.
> Because of 
> https://github.com/apache/storm/commit/93a7f770d508668bc7af183e08535813fff6f805
>  (STORM-3660)
> the "_credentials" stream is removed.
> So the map of streamId to streamName for system component is changed 
> refer to the code at:
> https://github.com/apache/storm/blob/v2.2.0/storm-client/src/jvm/org/apache/storm/serialization/SerializationFactory.java#L218-L222
> So a worker running on storm-client-2.2 might send out __metrics from its 
> systembolt, while the MetricsConsumer running with storm-client-2.3 
> interprets it as "__metrics_tick" because the mapping is different:
> {code:java}
> o.a.s.s.SerializationFactory Thread-15-__system-executor[-1, -1] [INFO] idmap 
> for system comp {__tick=6, __system=5, __metrics_tick=4, __credentials=1, 
> __flush=2, __metrics=3}
> {code}
> vs
> {code:java}
> o.a.s.s.SerializationFactory Netty-server-localhost-6703-worker-1 [INFO] 
> idmap for system comp {__tick=5, __system=4, __metrics_tick=3, __flush=1, 
> __metrics=2}
> {code}
> Hence we see
> {code:java}
> Caused by: java.lang.RuntimeException: java.lang.ClassCastException: 
> org.apache.storm.metric.api.IMetricsConsumer$TaskInfo cannot be cast to 
> java.lang.Integer
> at org.apache.storm.executor.Executor.accept(Executor.java:293) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:113) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consume(JCQueue.java:89) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:167) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:153) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$1.run(Utils.java:398) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> ... 1 more
> Caused by: java.lang.ClassCastException: 
> org.apache.storm.metric.api.IMetricsConsumer$TaskInfo cannot be cast to 
> java.lang.Integer
> at org.apache.storm.tuple.TupleImpl.getInteger(TupleImpl.java:121) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.executor.Executor.metricsTick(Executor.java:320) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor.tupleActionFn(BoltExecutor.java:213)
>  ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.executor.Executor.accept(Executor.java:286) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:113) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consume(JCQueue.java:89) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:167) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:153) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$1.run(Utils.java:398) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> ... 1 more
> 2020-08-04 18:26:08.017 o.a.s.m.c
> 2020-08-04 18:26:08.027 o.a.s.u.Utils 
> Thread-19-__metrics_org.apache.storm.metric.LoggingMetricsConsumer-executor[1555,
>  1555] [ERROR] Halting process: Worker died
> java.lang.RuntimeException: Halting process: Worker died
> at org.apache.storm.utils.Utils.exitProcess(Utils.java:518) 
> [storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$3.run(Utils.java:870) 
> [storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.error.ReportErrorAndDie.uncaughtException(ReportErrorAndDie.java:41)
>  [storm-client-2.3.0.y.jar:2.3.0.y]
> at java.lang.Thread.dispatchUncaughtException(Thread.java:1959) 
> [?:1.8.0_242]
> 2020-08-04 18:26:08.027 o.a.s.u.Utils 
> 

[jira] [Resolved] (STORM-3687) Add a warning about possible issues on a mixed cluster if the StormCommon.systemTopology implementation is changed

2020-08-05 Thread Ethan Li (Jira)


 [ 
https://issues.apache.org/jira/browse/STORM-3687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ethan Li resolved STORM-3687.
-
Fix Version/s: 2.3.0
   Resolution: Fixed

> Add a warning about possible issues on a mixed cluster if the 
> StormCommon.systemTopology implementation is changed
> --
>
> Key: STORM-3687
> URL: https://issues.apache.org/jira/browse/STORM-3687
> Project: Apache Storm
>  Issue Type: Task
>Reporter: Ethan Li
>Priority: Minor
> Fix For: 2.3.0
>
>  Time Spent: 20m
>  Remaining Estimate: 0h
>
> During rolling upgrade, some supervisors are still at 2.2, and others are 
> running on 2.3. So some workers are running with storm-client-2.2.jar and 
> others are on 2.3.
> Because of 
> https://github.com/apache/storm/commit/93a7f770d508668bc7af183e08535813fff6f805
>  (STORM-3660)
> the "_credentials" stream is removed.
> So the map of streamId to streamName for system component is changed 
> refer to the code at:
> https://github.com/apache/storm/blob/v2.2.0/storm-client/src/jvm/org/apache/storm/serialization/SerializationFactory.java#L218-L222
> So a worker running on storm-client-2.2 might send out __metrics from its 
> systembolt, while the MetricsConsumer running with storm-client-2.3 
> interprets it as "__metrics_tick" because the mapping is different:
> {code:java}
> o.a.s.s.SerializationFactory Thread-15-__system-executor[-1, -1] [INFO] idmap 
> for system comp {__tick=6, __system=5, __metrics_tick=4, __credentials=1, 
> __flush=2, __metrics=3}
> {code}
> vs
> {code:java}
> o.a.s.s.SerializationFactory Netty-server-localhost-6703-worker-1 [INFO] 
> idmap for system comp {__tick=5, __system=4, __metrics_tick=3, __flush=1, 
> __metrics=2}
> {code}
> Hence we see
> {code:java}
> Caused by: java.lang.RuntimeException: java.lang.ClassCastException: 
> org.apache.storm.metric.api.IMetricsConsumer$TaskInfo cannot be cast to 
> java.lang.Integer
> at org.apache.storm.executor.Executor.accept(Executor.java:293) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:113) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consume(JCQueue.java:89) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:167) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:153) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$1.run(Utils.java:398) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> ... 1 more
> Caused by: java.lang.ClassCastException: 
> org.apache.storm.metric.api.IMetricsConsumer$TaskInfo cannot be cast to 
> java.lang.Integer
> at org.apache.storm.tuple.TupleImpl.getInteger(TupleImpl.java:121) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.executor.Executor.metricsTick(Executor.java:320) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor.tupleActionFn(BoltExecutor.java:213)
>  ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.executor.Executor.accept(Executor.java:286) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:113) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consume(JCQueue.java:89) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:167) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:153) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$1.run(Utils.java:398) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> ... 1 more
> 2020-08-04 18:26:08.017 o.a.s.m.c
> 2020-08-04 18:26:08.027 o.a.s.u.Utils 
> Thread-19-__metrics_org.apache.storm.metric.LoggingMetricsConsumer-executor[1555,
>  1555] [ERROR] Halting process: Worker died
> java.lang.RuntimeException: Halting process: Worker died
> at org.apache.storm.utils.Utils.exitProcess(Utils.java:518) 
> [storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$3.run(Utils.java:870) 
> [storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.error.ReportErrorAndDie.uncaughtException(ReportErrorAndDie.java:41)
>  [storm-client-2.3.0.y.jar:2.3.0.y]
> at java.lang.Thread.dispatchUncaughtException(Thread.java:1959) 
> [?:1.8.0_242]
> 2020-08-04 18:26:08.027 o.a.s.u.Utils 
> Thread-18-__metrics_org.apache.storm.metric.LoggingMetricsConsumer-executor[1553,
>  1553] [ERROR] Halting process: Worker died

[jira] [Assigned] (STORM-3687) Add a warning about possible issues on a mixed cluster if the StormCommon.systemTopology implementation is changed

2020-08-05 Thread Ethan Li (Jira)


 [ 
https://issues.apache.org/jira/browse/STORM-3687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ethan Li reassigned STORM-3687:
---

Assignee: Ethan Li

> Add a warning about possible issues on a mixed cluster if the 
> StormCommon.systemTopology implementation is changed
> --
>
> Key: STORM-3687
> URL: https://issues.apache.org/jira/browse/STORM-3687
> Project: Apache Storm
>  Issue Type: Task
>Reporter: Ethan Li
>Assignee: Ethan Li
>Priority: Minor
> Fix For: 2.3.0
>
>  Time Spent: 20m
>  Remaining Estimate: 0h
>
> During rolling upgrade, some supervisors are still at 2.2, and others are 
> running on 2.3. So some workers are running with storm-client-2.2.jar and 
> others are on 2.3.
> Because of 
> https://github.com/apache/storm/commit/93a7f770d508668bc7af183e08535813fff6f805
>  (STORM-3660)
> the "_credentials" stream is removed.
> So the map of streamId to streamName for system component is changed 
> refer to the code at:
> https://github.com/apache/storm/blob/v2.2.0/storm-client/src/jvm/org/apache/storm/serialization/SerializationFactory.java#L218-L222
> So a worker running on storm-client-2.2 might send out __metrics from its 
> systembolt, while the MetricsConsumer running with storm-client-2.3 
> interprets it as "__metrics_tick" because the mapping is different:
> {code:java}
> o.a.s.s.SerializationFactory Thread-15-__system-executor[-1, -1] [INFO] idmap 
> for system comp {__tick=6, __system=5, __metrics_tick=4, __credentials=1, 
> __flush=2, __metrics=3}
> {code}
> vs
> {code:java}
> o.a.s.s.SerializationFactory Netty-server-localhost-6703-worker-1 [INFO] 
> idmap for system comp {__tick=5, __system=4, __metrics_tick=3, __flush=1, 
> __metrics=2}
> {code}
> Hence we see
> {code:java}
> Caused by: java.lang.RuntimeException: java.lang.ClassCastException: 
> org.apache.storm.metric.api.IMetricsConsumer$TaskInfo cannot be cast to 
> java.lang.Integer
> at org.apache.storm.executor.Executor.accept(Executor.java:293) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:113) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consume(JCQueue.java:89) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:167) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:153) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$1.run(Utils.java:398) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> ... 1 more
> Caused by: java.lang.ClassCastException: 
> org.apache.storm.metric.api.IMetricsConsumer$TaskInfo cannot be cast to 
> java.lang.Integer
> at org.apache.storm.tuple.TupleImpl.getInteger(TupleImpl.java:121) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.executor.Executor.metricsTick(Executor.java:320) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor.tupleActionFn(BoltExecutor.java:213)
>  ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.executor.Executor.accept(Executor.java:286) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:113) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consume(JCQueue.java:89) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:167) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:153) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$1.run(Utils.java:398) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> ... 1 more
> 2020-08-04 18:26:08.017 o.a.s.m.c
> 2020-08-04 18:26:08.027 o.a.s.u.Utils 
> Thread-19-__metrics_org.apache.storm.metric.LoggingMetricsConsumer-executor[1555,
>  1555] [ERROR] Halting process: Worker died
> java.lang.RuntimeException: Halting process: Worker died
> at org.apache.storm.utils.Utils.exitProcess(Utils.java:518) 
> [storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$3.run(Utils.java:870) 
> [storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.error.ReportErrorAndDie.uncaughtException(ReportErrorAndDie.java:41)
>  [storm-client-2.3.0.y.jar:2.3.0.y]
> at java.lang.Thread.dispatchUncaughtException(Thread.java:1959) 
> [?:1.8.0_242]
> 2020-08-04 18:26:08.027 o.a.s.u.Utils 
> Thread-18-__metrics_org.apache.storm.metric.LoggingMetricsConsumer-executor[1553,
>  1553] [ERROR] Halting process: 

[jira] [Updated] (STORM-3687) Add a warning about possible issues on a mixed cluster if the StormCommon.systemTopology implementation is changed

2020-08-05 Thread Ethan Li (Jira)


 [ 
https://issues.apache.org/jira/browse/STORM-3687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ethan Li updated STORM-3687:

Summary: Add a warning about possible issues on a mixed cluster if the 
StormCommon.systemTopology implementation is changed  (was: MetricsConsumer has 
ClassCastException on a mixed cluster)

> Add a warning about possible issues on a mixed cluster if the 
> StormCommon.systemTopology implementation is changed
> --
>
> Key: STORM-3687
> URL: https://issues.apache.org/jira/browse/STORM-3687
> Project: Apache Storm
>  Issue Type: Bug
>Reporter: Ethan Li
>Priority: Minor
>  Time Spent: 20m
>  Remaining Estimate: 0h
>
> During rolling upgrade, some supervisors are still at 2.2, and others are 
> running on 2.3. So some workers are running with storm-client-2.2.jar and 
> others are on 2.3.
> Because of 
> https://github.com/apache/storm/commit/93a7f770d508668bc7af183e08535813fff6f805
>  (STORM-3660)
> the "_credentials" stream is removed.
> So the map of streamId to streamName for system component is changed 
> refer to the code at:
> https://github.com/apache/storm/blob/v2.2.0/storm-client/src/jvm/org/apache/storm/serialization/SerializationFactory.java#L218-L222
> So a worker running on storm-client-2.2 might send out __metrics from its 
> systembolt, while the MetricsConsumer running with storm-client-2.3 
> interprets it as "__metrics_tick" because the mapping is different:
> {code:java}
> o.a.s.s.SerializationFactory Thread-15-__system-executor[-1, -1] [INFO] idmap 
> for system comp {__tick=6, __system=5, __metrics_tick=4, __credentials=1, 
> __flush=2, __metrics=3}
> {code}
> vs
> {code:java}
> o.a.s.s.SerializationFactory Netty-server-localhost-6703-worker-1 [INFO] 
> idmap for system comp {__tick=5, __system=4, __metrics_tick=3, __flush=1, 
> __metrics=2}
> {code}
> Hence we see
> {code:java}
> Caused by: java.lang.RuntimeException: java.lang.ClassCastException: 
> org.apache.storm.metric.api.IMetricsConsumer$TaskInfo cannot be cast to 
> java.lang.Integer
> at org.apache.storm.executor.Executor.accept(Executor.java:293) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:113) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consume(JCQueue.java:89) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:167) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:153) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$1.run(Utils.java:398) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> ... 1 more
> Caused by: java.lang.ClassCastException: 
> org.apache.storm.metric.api.IMetricsConsumer$TaskInfo cannot be cast to 
> java.lang.Integer
> at org.apache.storm.tuple.TupleImpl.getInteger(TupleImpl.java:121) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.executor.Executor.metricsTick(Executor.java:320) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor.tupleActionFn(BoltExecutor.java:213)
>  ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.executor.Executor.accept(Executor.java:286) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:113) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consume(JCQueue.java:89) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:167) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:153) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$1.run(Utils.java:398) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> ... 1 more
> 2020-08-04 18:26:08.017 o.a.s.m.c
> 2020-08-04 18:26:08.027 o.a.s.u.Utils 
> Thread-19-__metrics_org.apache.storm.metric.LoggingMetricsConsumer-executor[1555,
>  1555] [ERROR] Halting process: Worker died
> java.lang.RuntimeException: Halting process: Worker died
> at org.apache.storm.utils.Utils.exitProcess(Utils.java:518) 
> [storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$3.run(Utils.java:870) 
> [storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.error.ReportErrorAndDie.uncaughtException(ReportErrorAndDie.java:41)
>  [storm-client-2.3.0.y.jar:2.3.0.y]
> at java.lang.Thread.dispatchUncaughtException(Thread.java:1959) 
> [?:1.8.0_242]
> 2020-08-04 18:26:08.027 o.a.s.u.Utils 
> 

[jira] [Updated] (STORM-3687) Add a warning about possible issues on a mixed cluster if the StormCommon.systemTopology implementation is changed

2020-08-05 Thread Ethan Li (Jira)


 [ 
https://issues.apache.org/jira/browse/STORM-3687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ethan Li updated STORM-3687:

Issue Type: Task  (was: Bug)

> Add a warning about possible issues on a mixed cluster if the 
> StormCommon.systemTopology implementation is changed
> --
>
> Key: STORM-3687
> URL: https://issues.apache.org/jira/browse/STORM-3687
> Project: Apache Storm
>  Issue Type: Task
>Reporter: Ethan Li
>Priority: Minor
>  Time Spent: 20m
>  Remaining Estimate: 0h
>
> During rolling upgrade, some supervisors are still at 2.2, and others are 
> running on 2.3. So some workers are running with storm-client-2.2.jar and 
> others are on 2.3.
> Because of 
> https://github.com/apache/storm/commit/93a7f770d508668bc7af183e08535813fff6f805
>  (STORM-3660)
> the "_credentials" stream is removed.
> So the map of streamId to streamName for system component is changed 
> refer to the code at:
> https://github.com/apache/storm/blob/v2.2.0/storm-client/src/jvm/org/apache/storm/serialization/SerializationFactory.java#L218-L222
> So a worker running on storm-client-2.2 might send out __metrics from its 
> systembolt, while the MetricsConsumer running with storm-client-2.3 
> interprets it as "__metrics_tick" because the mapping is different:
> {code:java}
> o.a.s.s.SerializationFactory Thread-15-__system-executor[-1, -1] [INFO] idmap 
> for system comp {__tick=6, __system=5, __metrics_tick=4, __credentials=1, 
> __flush=2, __metrics=3}
> {code}
> vs
> {code:java}
> o.a.s.s.SerializationFactory Netty-server-localhost-6703-worker-1 [INFO] 
> idmap for system comp {__tick=5, __system=4, __metrics_tick=3, __flush=1, 
> __metrics=2}
> {code}
> Hence we see
> {code:java}
> Caused by: java.lang.RuntimeException: java.lang.ClassCastException: 
> org.apache.storm.metric.api.IMetricsConsumer$TaskInfo cannot be cast to 
> java.lang.Integer
> at org.apache.storm.executor.Executor.accept(Executor.java:293) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:113) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consume(JCQueue.java:89) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:167) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:153) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$1.run(Utils.java:398) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> ... 1 more
> Caused by: java.lang.ClassCastException: 
> org.apache.storm.metric.api.IMetricsConsumer$TaskInfo cannot be cast to 
> java.lang.Integer
> at org.apache.storm.tuple.TupleImpl.getInteger(TupleImpl.java:121) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.executor.Executor.metricsTick(Executor.java:320) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor.tupleActionFn(BoltExecutor.java:213)
>  ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.executor.Executor.accept(Executor.java:286) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:113) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consume(JCQueue.java:89) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:167) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:153) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$1.run(Utils.java:398) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> ... 1 more
> 2020-08-04 18:26:08.017 o.a.s.m.c
> 2020-08-04 18:26:08.027 o.a.s.u.Utils 
> Thread-19-__metrics_org.apache.storm.metric.LoggingMetricsConsumer-executor[1555,
>  1555] [ERROR] Halting process: Worker died
> java.lang.RuntimeException: Halting process: Worker died
> at org.apache.storm.utils.Utils.exitProcess(Utils.java:518) 
> [storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$3.run(Utils.java:870) 
> [storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.error.ReportErrorAndDie.uncaughtException(ReportErrorAndDie.java:41)
>  [storm-client-2.3.0.y.jar:2.3.0.y]
> at java.lang.Thread.dispatchUncaughtException(Thread.java:1959) 
> [?:1.8.0_242]
> 2020-08-04 18:26:08.027 o.a.s.u.Utils 
> Thread-18-__metrics_org.apache.storm.metric.LoggingMetricsConsumer-executor[1553,
>  1553] [ERROR] Halting process: Worker died
> java.lang.RuntimeException: Halting process: 

[jira] [Updated] (STORM-3687) MetricsConsumer has ClassCastException on a mixed cluster

2020-08-05 Thread Ethan Li (Jira)


 [ 
https://issues.apache.org/jira/browse/STORM-3687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ethan Li updated STORM-3687:

Priority: Minor  (was: Major)

> MetricsConsumer has ClassCastException on a mixed cluster
> -
>
> Key: STORM-3687
> URL: https://issues.apache.org/jira/browse/STORM-3687
> Project: Apache Storm
>  Issue Type: Bug
>Reporter: Ethan Li
>Priority: Minor
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> During rolling upgrade, some supervisors are still at 2.2, and others are 
> running on 2.3. So some workers are running with storm-client-2.2.jar and 
> others are on 2.3.
> Because of 
> https://github.com/apache/storm/commit/93a7f770d508668bc7af183e08535813fff6f805
>  (STORM-3660)
> the "_credentials" stream is removed.
> So the map of streamId to streamName for system component is changed 
> refer to the code at:
> https://github.com/apache/storm/blob/v2.2.0/storm-client/src/jvm/org/apache/storm/serialization/SerializationFactory.java#L218-L222
> So a worker running on storm-client-2.2 might send out __metrics from its 
> systembolt, while the MetricsConsumer running with storm-client-2.3 
> interprets it as "__metrics_tick" because the mapping is different:
> {code:java}
> o.a.s.s.SerializationFactory Thread-15-__system-executor[-1, -1] [INFO] idmap 
> for system comp {__tick=6, __system=5, __metrics_tick=4, __credentials=1, 
> __flush=2, __metrics=3}
> {code}
> vs
> {code:java}
> o.a.s.s.SerializationFactory Netty-server-localhost-6703-worker-1 [INFO] 
> idmap for system comp {__tick=5, __system=4, __metrics_tick=3, __flush=1, 
> __metrics=2}
> {code}
> Hence we see
> {code:java}
> Caused by: java.lang.RuntimeException: java.lang.ClassCastException: 
> org.apache.storm.metric.api.IMetricsConsumer$TaskInfo cannot be cast to 
> java.lang.Integer
> at org.apache.storm.executor.Executor.accept(Executor.java:293) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:113) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consume(JCQueue.java:89) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:167) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:153) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$1.run(Utils.java:398) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> ... 1 more
> Caused by: java.lang.ClassCastException: 
> org.apache.storm.metric.api.IMetricsConsumer$TaskInfo cannot be cast to 
> java.lang.Integer
> at org.apache.storm.tuple.TupleImpl.getInteger(TupleImpl.java:121) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.executor.Executor.metricsTick(Executor.java:320) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor.tupleActionFn(BoltExecutor.java:213)
>  ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.executor.Executor.accept(Executor.java:286) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:113) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.JCQueue.consume(JCQueue.java:89) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:167) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:153) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$1.run(Utils.java:398) 
> ~[storm-client-2.3.0.y.jar:2.3.0.y]
> ... 1 more
> 2020-08-04 18:26:08.017 o.a.s.m.c
> 2020-08-04 18:26:08.027 o.a.s.u.Utils 
> Thread-19-__metrics_org.apache.storm.metric.LoggingMetricsConsumer-executor[1555,
>  1555] [ERROR] Halting process: Worker died
> java.lang.RuntimeException: Halting process: Worker died
> at org.apache.storm.utils.Utils.exitProcess(Utils.java:518) 
> [storm-client-2.3.0.y.jar:2.3.0.y]
> at org.apache.storm.utils.Utils$3.run(Utils.java:870) 
> [storm-client-2.3.0.y.jar:2.3.0.y]
> at 
> org.apache.storm.executor.error.ReportErrorAndDie.uncaughtException(ReportErrorAndDie.java:41)
>  [storm-client-2.3.0.y.jar:2.3.0.y]
> at java.lang.Thread.dispatchUncaughtException(Thread.java:1959) 
> [?:1.8.0_242]
> 2020-08-04 18:26:08.027 o.a.s.u.Utils 
> Thread-18-__metrics_org.apache.storm.metric.LoggingMetricsConsumer-executor[1553,
>  1553] [ERROR] Halting process: Worker died
> java.lang.RuntimeException: Halting process: Worker died
> at org.apache.storm.utils.Utils.exitProcess(Utils.java:518) 
> [storm-client-2.3.0.y.jar:2.3.0.y]

[jira] [Created] (STORM-3687) MetricsConsumer has ClassCastException on a mixed cluster

2020-08-05 Thread Ethan Li (Jira)
Ethan Li created STORM-3687:
---

 Summary: MetricsConsumer has ClassCastException on a mixed cluster
 Key: STORM-3687
 URL: https://issues.apache.org/jira/browse/STORM-3687
 Project: Apache Storm
  Issue Type: Bug
Reporter: Ethan Li


During rolling upgrade, some supervisors are still at 2.2, and others are 
running on 2.3. So some workers are running with storm-client-2.2.jar and 
others are on 2.3.

Because of 
https://github.com/apache/storm/commit/93a7f770d508668bc7af183e08535813fff6f805 
(STORM-3660)

the "_credentials" stream is removed.
So the map of streamId to streamName for system component is changed 
refer to the code at:
https://github.com/apache/storm/blob/v2.2.0/storm-client/src/jvm/org/apache/storm/serialization/SerializationFactory.java#L218-L222


So a worker running on storm-client-2.2 might send out __metrics from its 
systembolt, while the MetricsConsumer running with storm-client-2.3 interprets 
it as "__metrics_tick" because the mapping is different:

{code:java}
o.a.s.s.SerializationFactory Thread-15-__system-executor[-1, -1] [INFO] idmap 
for system comp {__tick=6, __system=5, __metrics_tick=4, __credentials=1, 
__flush=2, __metrics=3}
{code}
vs
{code:java}
o.a.s.s.SerializationFactory Netty-server-localhost-6703-worker-1 [INFO] idmap 
for system comp {__tick=5, __system=4, __metrics_tick=3, __flush=1, __metrics=2}
{code}


Hence we see
{code:java}
Caused by: java.lang.RuntimeException: java.lang.ClassCastException: 
org.apache.storm.metric.api.IMetricsConsumer$TaskInfo cannot be cast to 
java.lang.Integer
at org.apache.storm.executor.Executor.accept(Executor.java:293) 
~[storm-client-2.3.0.y.jar:2.3.0.y]
at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:113) 
~[storm-client-2.3.0.y.jar:2.3.0.y]
at org.apache.storm.utils.JCQueue.consume(JCQueue.java:89) 
~[storm-client-2.3.0.y.jar:2.3.0.y]
at 
org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:167) 
~[storm-client-2.3.0.y.jar:2.3.0.y]
at 
org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:153) 
~[storm-client-2.3.0.y.jar:2.3.0.y]
at org.apache.storm.utils.Utils$1.run(Utils.java:398) 
~[storm-client-2.3.0.y.jar:2.3.0.y]
... 1 more
Caused by: java.lang.ClassCastException: 
org.apache.storm.metric.api.IMetricsConsumer$TaskInfo cannot be cast to 
java.lang.Integer
at org.apache.storm.tuple.TupleImpl.getInteger(TupleImpl.java:121) 
~[storm-client-2.3.0.y.jar:2.3.0.y]
at org.apache.storm.executor.Executor.metricsTick(Executor.java:320) 
~[storm-client-2.3.0.y.jar:2.3.0.y]
at 
org.apache.storm.executor.bolt.BoltExecutor.tupleActionFn(BoltExecutor.java:213)
 ~[storm-client-2.3.0.y.jar:2.3.0.y]
at org.apache.storm.executor.Executor.accept(Executor.java:286) 
~[storm-client-2.3.0.y.jar:2.3.0.y]
at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:113) 
~[storm-client-2.3.0.y.jar:2.3.0.y]
at org.apache.storm.utils.JCQueue.consume(JCQueue.java:89) 
~[storm-client-2.3.0.y.jar:2.3.0.y]
at 
org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:167) 
~[storm-client-2.3.0.y.jar:2.3.0.y]
at 
org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:153) 
~[storm-client-2.3.0.y.jar:2.3.0.y]
at org.apache.storm.utils.Utils$1.run(Utils.java:398) 
~[storm-client-2.3.0.y.jar:2.3.0.y]
... 1 more
2020-08-04 18:26:08.017 o.a.s.m.c



2020-08-04 18:26:08.027 o.a.s.u.Utils 
Thread-19-__metrics_org.apache.storm.metric.LoggingMetricsConsumer-executor[1555,
 1555] [ERROR] Halting process: Worker died
java.lang.RuntimeException: Halting process: Worker died
at org.apache.storm.utils.Utils.exitProcess(Utils.java:518) 
[storm-client-2.3.0.y.jar:2.3.0.y]
at org.apache.storm.utils.Utils$3.run(Utils.java:870) 
[storm-client-2.3.0.y.jar:2.3.0.y]
at 
org.apache.storm.executor.error.ReportErrorAndDie.uncaughtException(ReportErrorAndDie.java:41)
 [storm-client-2.3.0.y.jar:2.3.0.y]
at java.lang.Thread.dispatchUncaughtException(Thread.java:1959) 
[?:1.8.0_242]
2020-08-04 18:26:08.027 o.a.s.u.Utils 
Thread-18-__metrics_org.apache.storm.metric.LoggingMetricsConsumer-executor[1553,
 1553] [ERROR] Halting process: Worker died
java.lang.RuntimeException: Halting process: Worker died
at org.apache.storm.utils.Utils.exitProcess(Utils.java:518) 
[storm-client-2.3.0.y.jar:2.3.0.y]
at org.apache.storm.utils.Utils$3.run(Utils.java:870) 
[storm-client-2.3.0.y.jar:2.3.0.y]
at 
org.apache.storm.executor.error.ReportErrorAndDie.uncaughtException(ReportErrorAndDie.java:41)
 [storm-client-2.3.0.y.jar:2.3.0.y]
at java.lang.Thread.dispatchUncaughtException(Thread.java:1959) 
[?:1.8.0_242]
2020-08-04 18:26:08.028 o.a.s.u.Utils ShutdownHook-sleepKill-3s [INFO] Halting 
after 3 seconds
{code}


Since mixed cluster is 

[jira] [Updated] (STORM-3674) explicitly specify pip2 and pip3 in travis-install.sh

2020-08-05 Thread Ethan Li (Jira)


 [ 
https://issues.apache.org/jira/browse/STORM-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ethan Li updated STORM-3674:

Fix Version/s: 2.3.0

> explicitly specify pip2 and pip3 in travis-install.sh
> -
>
> Key: STORM-3674
> URL: https://issues.apache.org/jira/browse/STORM-3674
> Project: Apache Storm
>  Issue Type: Sub-task
>Reporter: liusheng
>Assignee: liusheng
>Priority: Major
> Fix For: 2.3.0
>
>  Time Spent: 20m
>  Remaining Estimate: 0h
>
> When I try to run Storm tests in Travis ARM containers, it will raise error 
> about python packages installation, because in Travis ARM containers, the 
> "pip" command refer to pip3 binary,  so the following commands in 
> travis-install.sh will not install required packages of Python2.
> {code:java}
> pip install --user -r ${TRAVIS_SCRIPT_DIR}/requirements.txt
> pip3 install --user -r ${TRAVIS_SCRIPT_DIR}/requirements.txt
> {code}
> it is better to explicitly specify pip2 and pip3 in the script.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Resolved] (STORM-3681) Enable basic Travis ARM CI job

2020-08-05 Thread Ethan Li (Jira)


 [ 
https://issues.apache.org/jira/browse/STORM-3681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ethan Li resolved STORM-3681.
-
Fix Version/s: 2.3.0
   Resolution: Fixed

Thanks [~seanlau]. I merged this to master 
(9986a335584d322f6cf632bcc8326f974583ece1)

> Enable basic Travis ARM CI job
> --
>
> Key: STORM-3681
> URL: https://issues.apache.org/jira/browse/STORM-3681
> Project: Apache Storm
>  Issue Type: Sub-task
>Reporter: liusheng
>Assignee: liusheng
>Priority: Major
> Fix For: 2.3.0
>
>  Time Spent: 1h 20m
>  Remaining Estimate: 0h
>
> Until now, we have tried many times about adding Travis ARM CI jobs for 
> Storm, and have made some small fixes. For Storm itself, we have tested 
> building and running tests, it looks there isn't any block issue for ARM64 
> platform. But in my testing, the Travis CI system seems have some problems 
> about supporting ARM, there are some existed issues in Travis community about 
> this, for example:
>  # ARM CI job hang no reason: 
> [https://travis-ci.community/t/output-is-truncated-heavily-in-arm64-when-a-command-hangs/7630]
>  # Disk quota exceeded in ARM CI job: 
> [https://travis-ci.community/t/disk-quota-exceeded-on-ppc64le/8006/4]
> But it is OK to enable basic ARM CI just like *s390x* support does see: 
> https://issues.apache.org/jira/browse/STORM-3401
>  We have verfied and it run OK, see: [https://github.com/liusheng/storm/pulls]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (STORM-3686) o.a.s.t.s.AbstractNonblockingServer$FrameBuffer pool-14-thread-10 [ERROR] Unexpected throwable while invoking! java.lang.NullPointerException: null

2020-08-05 Thread Saurav Suman (Jira)


[ 
https://issues.apache.org/jira/browse/STORM-3686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171538#comment-17171538
 ] 

Saurav Suman commented on STORM-3686:
-

Hi Team,

Any help and solution for this issue.  

> o.a.s.t.s.AbstractNonblockingServer$FrameBuffer pool-14-thread-10 [ERROR] 
> Unexpected throwable while invoking! java.lang.NullPointerException: null
> ---
>
> Key: STORM-3686
> URL: https://issues.apache.org/jira/browse/STORM-3686
> Project: Apache Storm
>  Issue Type: Bug
>Affects Versions: 1.2.2
> Environment: PROD
>Reporter: Saurav Suman
>Priority: Blocker
> Attachments: Storm_ui.log, storm_nimbus.log
>
>
> Hi Team,
>  
> Very often I am getting below error in storm nimbus and after that the storm 
> UI loads only with some content.
>  
> 2020-08-05 02:45:01.802 o.a.s.t.s.AbstractNonblockingServer$FrameBuffer 
> pool-14-thread-10 [ERROR] Unexpected throwable while invoking!
>  java.lang.NullPointerException: null
>  
> Attached the storm nimbus and ui error from their logs.
>  
> Please advise.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)