Skip to content

Commit

Permalink
ALS-6511: Attempt to fix snappy codec bug
Browse files Browse the repository at this point in the history
  • Loading branch information
ramari16 committed Jul 23, 2024
1 parent 7bc1109 commit e0f9fad
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -72,8 +72,8 @@ public void writeHeader(String[] data) {
dataFileWriter = new DataFileWriter<GenericRecord>(datumWriter);
try {
log.info("Creating temp avro file at " + file.getAbsoluteFile());
dataFileWriter.create(entitySchema, file);
dataFileWriter.setCodec(CodecFactory.deflateCodec(5));
dataFileWriter.create(entitySchema, file);
} catch (IOException e) {
throw new UncheckedIOException(e);
}
Expand Down

0 comments on commit e0f9fad

Please sign in to comment.