[ https://issues.apache.org/jira/browse/KAFKA-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15902125#comment-15902125 ]
ASF GitHub Bot commented on KAFKA-4840: --------------------------------------- GitHub user smccauliff opened a pull request: https://github.com/apache/kafka/pull/2659 KAFKA-4840 : BufferPool errors can cause buffer pool to go into a bad state You can merge this pull request into a Git repository by running: $ git pull https://github.com/smccauliff/kafka kafka-4840 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2659.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #2659 ---- commit fe201ae279861c534f2f2e3513898d7ce292d5fe Author: Sean McCauliff <smccaul...@linkedin.com> Date: 2017-03-07T02:58:40Z Remove more memory condition variable on throwable or sensor exception. commit 36b9265216b1a916ddbb4a7bff8f26a910b0fe0b Author: Sean McCauliff <smccaul...@linkedin.com> Date: 2017-03-07T06:37:55Z Test sensor report exception. commit 7e4997b308e29ce5a20df1c50e30eec3a275a74e Author: Sean McCauliff <smccaul...@linkedin.com> Date: 2017-03-07T15:39:26Z Fix checkstyle violations. Readability. commit f353afcf272e849b5f60ce0af653916240bebd7d Author: Sean McCauliff <smccaul...@linkedin.com> Date: 2017-03-08T22:30:52Z Restore avaialble memory count on exception. ---- > There are are still cases where producer buffer pool will not remove waiters. > ----------------------------------------------------------------------------- > > Key: KAFKA-4840 > URL: https://issues.apache.org/jira/browse/KAFKA-4840 > Project: Kafka > Issue Type: Bug > Components: clients > Affects Versions: 0.10.2.0 > Reporter: Sean McCauliff > > In BufferPool.allocate(int size, long maxTimeToBlockMs): > If a Throwable other than InterruptedException is thrown out of await() for > some reason or if there is an exception thrown in the corresponding finally > block around the await(), for example if waitTime.record(.....) throws an > exception, then the waiters are not removed from the waiters deque. -- This message was sent by Atlassian JIRA (v6.3.15#6346)