[
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 <[email protected]>
Date: 2017-03-07T02:58:40Z
Remove more memory condition variable on throwable or sensor exception.
commit 36b9265216b1a916ddbb4a7bff8f26a910b0fe0b
Author: Sean McCauliff <[email protected]>
Date: 2017-03-07T06:37:55Z
Test sensor report exception.
commit 7e4997b308e29ce5a20df1c50e30eec3a275a74e
Author: Sean McCauliff <[email protected]>
Date: 2017-03-07T15:39:26Z
Fix checkstyle violations.
Readability.
commit f353afcf272e849b5f60ce0af653916240bebd7d
Author: Sean McCauliff <[email protected]>
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)
