----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/58470/ -----------------------------------------------------------
Review request for Flume. Bugs: FLUME-3084 https://issues.apache.org/jira/browse/FLUME-3084 Repository: flume-git Description ------- This is with reference to FLUME-3084, make HDFSEventSink and BucketWriter extensible so that we can roll the file whenever avro schema version changes in the stream of events. Diffs ----- flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java 62e5383b flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java 741f01e7 flume-ng-sinks/flume-hdfs-sink/src/test/java/org/apache/flume/sink/hdfs/TestHDFSEventSink.java 782cf47c Diff: https://reviews.apache.org/r/58470/diff/1/ Testing ------- Existing test cases are fine, no new logic implemented. Thanks, Kallam Reddy