kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nehanarkh...@apache.org
Subject kafka git commit: KAFKA-1739 Remove testComplexCompressDecompress in MessageCompressionTest; reviewed by Neha Narkhede
Date Mon, 10 Nov 2014 04:24:41 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk f20e5108a -> 9b3da9fbf


KAFKA-1739 Remove testComplexCompressDecompress in MessageCompressionTest; reviewed by Neha
Narkhede


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/9b3da9fb
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/9b3da9fb
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/9b3da9fb

Branch: refs/heads/trunk
Commit: 9b3da9fbfd60e3a0482ec7bd615dc9806cd9941c
Parents: f20e510
Author: Manikumar Reddy <manikumar.reddy@gmail.com>
Authored: Sun Nov 9 20:23:46 2014 -0800
Committer: Neha Narkhede <neha.narkhede@gmail.com>
Committed: Sun Nov 9 20:24:35 2014 -0800

----------------------------------------------------------------------
 .../scala/unit/kafka/message/MessageCompressionTest.scala   | 9 ---------
 1 file changed, 9 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/9b3da9fb/core/src/test/scala/unit/kafka/message/MessageCompressionTest.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/unit/kafka/message/MessageCompressionTest.scala b/core/src/test/scala/unit/kafka/message/MessageCompressionTest.scala
index 0bb275d..76987d4 100644
--- a/core/src/test/scala/unit/kafka/message/MessageCompressionTest.scala
+++ b/core/src/test/scala/unit/kafka/message/MessageCompressionTest.scala
@@ -44,15 +44,6 @@ class MessageCompressionTest extends JUnitSuite {
     assertEquals(messages, decompressed)
   }
 
-  @Test
-  def testComplexCompressDecompress() {
-    val messages = List(new Message("hi there".getBytes), new Message("I am fine".getBytes),
new Message("I am not so well today".getBytes))
-    val message = new ByteBufferMessageSet(compressionCodec = DefaultCompressionCodec, messages
= messages.slice(0, 2):_*)
-    val complexMessages = List(message.shallowIterator.next.message):::messages.slice(2,3)
-    val complexMessage = new ByteBufferMessageSet(compressionCodec = DefaultCompressionCodec,
messages = complexMessages:_*)
-    val decompressedMessages = complexMessage.iterator.map(_.message).toList
-    assertEquals(messages, decompressedMessages)
-  }
   
   def isSnappyAvailable(): Boolean = {
     try {


Mime
View raw message