Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2762#discussion_r202345723
--- Diff:
storm-client/src/jvm/org/apache/storm/messaging/netty/StormClientHandler.java
---
@@ -47,12 +47,24 @@ 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) {
+ //Just in case we get something we are confused
about
+ // we can continue processing the rest of the tasks
+ LOG.error("BP index out of bounds {}", e);
--- End diff --
Ah! I realized `e` is bound to {} so my suggestion is already applied (show
index within same line), but no stack trace.
---
