BoundedByteBufferReceive hides OutOfMemoryError
-----------------------------------------------
Key: KAFKA-204
URL: https://issues.apache.org/jira/browse/KAFKA-204
Project: Kafka
Issue Type: Bug
Affects Versions: 0.7
Reporter: Chris Burroughs
Priority: Critical
private def byteBufferAllocate(size: Int): ByteBuffer = {
var buffer: ByteBuffer = null
try {
buffer = ByteBuffer.allocate(size)
}
catch {
case e: OutOfMemoryError =>
throw new RuntimeException("OOME with size " + size, e)
case e2 =>
throw e2
}
buffer
}
This hides the fact that an Error occurred, and will likely result in some log
handler printing a message, instead of exiting with non-zero status. Knowing
how large the allocation was that caused an OOM is really nice, so I'd suggest
logging in byteBufferAllocate and then re-throwing OutOfMemoryError
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
