Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
"this.waiters.remove(moreMemory);" should happen before the exception
is thrown.
.Otherwise the waiting thread count will never get to 0 after the exception
and batching will not occur. This is because in the RecordAccumulator.ready
method the exhausted is set as
boolean exhausted = this.free.queued() > 0 where free.queued() returns the
waiters.size().