Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2762#discussion_r202196741
--- Diff:
storm-client/src/jvm/org/apache/storm/messaging/netty/StormClientHandler.java
---
@@ -47,12 +47,20 @@ public void channelRead(ChannelHandlerContext ctx,
Object message) throws Except
BackPressureStatus status = (BackPressureStatus) message;
if (status.bpTasks != null) {
for (Integer bpTask : status.bpTasks) {
- remoteBpStatus[bpTask].set(true);
+ try {
+ remoteBpStatus[bpTask].set(true);
+ } catch (ArrayIndexOutOfBoundsException e) {
--- End diff --
Could this happen in normal situation? I guess we don't expect it. I don't
think catching exception would hurt, but just to be sure about this.
---
