kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject svn commit: r1205659 - /incubator/kafka/trunk/core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala
Date Wed, 23 Nov 2011 23:25:15 GMT
Author: junrao
Date: Wed Nov 23 23:25:14 2011
New Revision: 1205659

URL: http://svn.apache.org/viewvc?rev=1205659&view=rev
Log:
AsyncProducerStats is not a singleton; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-207

Modified:
    incubator/kafka/trunk/core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala

Modified: incubator/kafka/trunk/core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala?rev=1205659&r1=1205658&r2=1205659&view=diff
==============================================================================
--- incubator/kafka/trunk/core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala
(original)
+++ incubator/kafka/trunk/core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala
Wed Nov 23 23:25:14 2011
@@ -80,8 +80,10 @@ private[kafka] class BoundedByteBufferRe
       buffer = ByteBuffer.allocate(size)
     }
     catch {
-      case e: OutOfMemoryError =>
-        throw new RuntimeException("OOME with size " + size, e)
+      case e: OutOfMemoryError => {
+        logger.error("OOME with size " + size, e)
+        throw e
+      }
       case e2 =>
         throw e2
     }



Mime
View raw message