Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2762#discussion_r202431877
--- 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 --
There is no way to disable backpressure right now. It didn't crash because
this is running under netty. Netty will catch the exception and pass it off
to an exception handler/the future. I didn't trace down the exact path and why
we were not handling this exception to cause it to come down, but I will file a
follow on JIRA to examine it.
---
