From 413d686562ce90760262b8c9777977c36c2dc4e2 Mon Sep 17 00:00:00 2001 From: Andrew Otto Date: Tue, 7 Jan 2014 12:39:39 -0500 Subject: [PATCH] Fixed missing import of DefaultCodec --- .../camus/etl/kafka/common/SequenceFileRecordWriterProvider.java | 1 + 1 file changed, 1 insertion(+) diff --git a/camus-etl-kafka/src/main/java/com/linkedin/camus/etl/kafka/common/SequenceFileRecordWriterProvider.java b/camus-etl-kafka/src/main/java/com/linkedin/camus/etl/kafka/common/SequenceFileRecordWriterProvider.java index 8437078f7..332416508 100644 --- a/camus-etl-kafka/src/main/java/com/linkedin/camus/etl/kafka/common/SequenceFileRecordWriterProvider.java +++ b/camus-etl-kafka/src/main/java/com/linkedin/camus/etl/kafka/common/SequenceFileRecordWriterProvider.java @@ -14,6 +14,7 @@ import org.apache.hadoop.io.SequenceFile; import org.apache.hadoop.io.SequenceFile.CompressionType; +import org.apache.hadoop.io.compress.DefaultCodec; import org.apache.hadoop.io.compress.CompressionCodec; import org.apache.hadoop.io.LongWritable; import org.apache.hadoop.io.Text;