You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by ju...@apache.org on 2011/11/24 00:40:23 UTC

svn commit: r1205662 - /incubator/kafka/trunk/core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala

Author: junrao
Date: Wed Nov 23 23:40:23 2011
New Revision: 1205662

URL: http://svn.apache.org/viewvc?rev=1205662&view=rev
Log:
revert previous commit r1205659 because of wrong commit message

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=1205662&r1=1205661&r2=1205662&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:40:23 2011
@@ -80,10 +80,8 @@ private[kafka] class BoundedByteBufferRe
       buffer = ByteBuffer.allocate(size)
     }
     catch {
-      case e: OutOfMemoryError => {
-        logger.error("OOME with size " + size, e)
-        throw e
-      }
+      case e: OutOfMemoryError =>
+        throw new RuntimeException("OOME with size " + size, e)
       case e2 =>
         throw e2
     }