kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Neha Narkhede <neha.narkh...@gmail.com>
Subject Re: CompressionUtilTest does not run and fails when it does
Date Sun, 06 Nov 2011 06:40:27 GMT
Joe,

Nice catch! This looks like a bug in the unit test. Do you want to
file a JIRA and submit a patch ?

Thanks,
Neha

On Sat, Nov 5, 2011 at 9:22 PM, Joe Stein <cryptcom@gmail.com> wrote:
> CompressionUtilTest does not run the functions inside of it during ./sbt
> test
>
> if you change CompressionUtilTest to extend JUnitSuite then the existing
> functions run (once you adorne them with @Test) but then fail ...
>
> I suspect the TestUtils.checkEquals(messages.iterator,
> decompressedMessages.iterator) is failing in testSimpleCompressDecompress
> because all of the messages are serialized into byte arrays and the entire
> set of messages compressed and that new compressed messages is what is
> returned as one message instead of the List[Message] and therefor are not
> interpreted within TestUtil.checkEquals to see this nuance.
>
> e.g.
>
> [error] Test Failed: testSimpleCompressDecompress
> junit.framework.AssertionFailedError: expected:<message(magic = 1,
> attributes = 0, crc = 3819140844, payload = java.nio.HeapByteBuffer[pos=0
> lim=8 cap=8])> but was:<MessageAndOffset(message(magic = 1, attributes = 0,
> crc = 3819140844, payload = java.nio.HeapByteBuffer[pos=0 lim=8 cap=8]),18)>
>
> and
>
> [error] Test Failed: testComplexCompressDecompress
> junit.framework.AssertionFailedError: expected:<2> but was:<3>
>
> Before opening a JIRA just wanted to check if maybe there was something
> that I was missing?
>
> /*
> Joe Stein
> http://www.linkedin.com/in/charmalloc
> Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop>
> */
>

Mime
View raw message