flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java (1 line): - line 247: // TODO : set proper compression type