kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joe Stein <crypt...@gmail.com>
Subject CompressionUtilTest does not run and fails when it does
Date Sun, 06 Nov 2011 04:22:15 GMT
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
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message