Hi Mayuresh,
Staying on the BufferPool.java, could you tell me why we need the following
piece of code
if (this.availableMemory > 0 || !this.free.isEmpty()) {
if (!this.waiters.isEmpty())
this.waiters.peekFirst().signal();
created a jira : https://issues.apache.org/jira/browse/KAFKA-3651
Thanks,
Mayuresh
On Tue, May 3, 2016 at 2:03 PM, Mayuresh Gharat
wrote:
> Nice catch. Do you have a jira for this?
> I can submit a patch right away. This should be a small patch.
>
> Thanks,
>
> Mayuresh
>
> On Tue, May 3, 2016
Nice catch. Do you have a jira for this?
I can submit a patch right away. This should be a small patch.
Thanks,
Mayuresh
On Tue, May 3, 2016 at 1:56 PM, Prabhu V wrote:
> Whenever the BufferPool throws a "Failed to allocate memory within the
> configured max blocking time" excepion, it should
