kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject svn commit: r1205662 - /incubator/kafka/trunk/core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala
Date Wed, 23 Nov 2011 23:40:23 GMT
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
     }



Mime
View raw message