-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/21663/#review43455
-----------------------------------------------------------
Test cases failing:
:clients:test
...
org.apache.kafka.common.record.MemoryRecordsTest > testIterator[3] FAILED
java.lang.IllegalArgumentException: Unknown compression type: LZ4
at
org.apache.kafka.common.record.Compressor.wrapForOutput(Compressor.java:212)
at org.apache.kafka.common.record.Compressor.<init>(Compressor.java:73)
at org.apache.kafka.common.record.Compressor.<init>(Compressor.java:77)
at
org.apache.kafka.common.record.MemoryRecords.<init>(MemoryRecords.java:45)
at
org.apache.kafka.common.record.MemoryRecords.emptyRecords(MemoryRecords.java:53)
at
org.apache.kafka.common.record.MemoryRecordsTest.testIterator(MemoryRecordsTest.java:42)
org.apache.kafka.common.record.MemoryRecordsTest > testIterator[4] FAILED
java.lang.IllegalArgumentException: Unknown compression type: LZ4HC
at
org.apache.kafka.common.record.Compressor.wrapForOutput(Compressor.java:212)
at org.apache.kafka.common.record.Compressor.<init>(Compressor.java:73)
at org.apache.kafka.common.record.Compressor.<init>(Compressor.java:77)
at
org.apache.kafka.common.record.MemoryRecords.<init>(MemoryRecords.java:45)
at
org.apache.kafka.common.record.MemoryRecords.emptyRecords(MemoryRecords.java:53)
at
org.apache.kafka.common.record.MemoryRecordsTest.testIterator(MemoryRecordsTest.java:42)
Working on this.
- James Oliver
On May 20, 2014, 1:19 a.m., James Oliver wrote:
>
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/21663/
> -----------------------------------------------------------
>
> (Updated May 20, 2014, 1:19 a.m.)
>
>
> Review request for kafka.
>
>
> Bugs: KAFKA-1456
> https://issues.apache.org/jira/browse/KAFKA-1456
>
>
> Repository: kafka
>
>
> Description
> -------
>
> Fix LZ4HC case object typo
>
>
> Revert unnecessary config changes, change server log folder to existing
> directory
>
>
> Add test cases for LZ4 and LZ4HC message compression
>
>
> Diffs
> -----
>
> build.gradle b3bbd775366e29abb960e11b0b613b3a85ac4747
> clients/src/main/java/org/apache/kafka/common/record/CompressionType.java
> c557e44b68bc201c7c7e8a31e9eb2f74c359762b
> clients/src/main/java/org/apache/kafka/common/record/Record.java
> ce1177ef3c851572a3e3268a7a075e7db56fc3f7
> config/producer.properties 52a76114f5d0968ca0ff01b3ab1a45450c0a1e33
> core/src/main/scala/kafka/message/CompressionCodec.scala
> 8762a790af2ab7f60a5e4e19955c7eb7ad7bc749
> core/src/main/scala/kafka/message/CompressionFactory.scala
> ca833ee317975548b3e0e91f010af36bce2af09b
> core/src/main/scala/kafka/message/Message.scala
> 52c082f5213ba48a39bf0d17e4ced2714276f0e0
> core/src/test/scala/unit/kafka/message/MessageCompressionTest.scala
> ed22931f24fed3530d374b56495a5e4bc89c72f2
> system_test/producer_perf/bin/run-compression-test-all.sh PRE-CREATION
> system_test/producer_perf/config/server.properties
> 9f8a633ab2f92862e7e7bcc40d699daf00c69e23
>
> Diff: https://reviews.apache.org/r/21663/diff/
>
>
> Testing
> -------
>
>
> Thanks,
>
> James Oliver
>
>