[ https://issues.apache.org/jira/browse/STORM-744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dongfang Qu updated STORM-744: ------------------------------ Description: storm-core/src/jvm/backtype/storm/messaging/netty/Server.java message_queue[i] = new LinkedBlockingQueue<ArrayList<TaskMessage>>(); // here was: storm-core/src/jvm/backtype/storm/messaging/netty/Server.java for (int i = 0; i < queueCount; i++) { message_queue[i] = new LinkedBlockingQueue<ArrayList<TaskMessage>>(); // here pendingMessages[i] = new AtomicInteger(0); } > downstream worker fail may lead to worker oom without limit pending > TaskMessage count > -------------------------------------------------------------------------------------- > > Key: STORM-744 > URL: https://issues.apache.org/jira/browse/STORM-744 > Project: Apache Storm > Issue Type: Bug > Affects Versions: 0.9.3, 0.10.0, 0.9.4, 0.11.0 > Reporter: Dongfang Qu > Assignee: Dongfang Qu > Priority: Minor > > storm-core/src/jvm/backtype/storm/messaging/netty/Server.java > message_queue[i] = new LinkedBlockingQueue<ArrayList<TaskMessage>>(); // here > -- This message was sent by Atlassian JIRA (v6.3.4#6332)