You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ne...@apache.org on 2014/11/10 05:24:41 UTC
kafka git commit: KAFKA-1739 Remove testComplexCompressDecompress in
MessageCompressionTest; reviewed by Neha Narkhede
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 <ma...@gmail.com>
Authored: Sun Nov 9 20:23:46 2014 -0800
Committer: Neha Narkhede <ne...@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 {