You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by Kallam Reddy <kl...@gmail.com> on 2017/04/16 14:34:18 UTC
Review Request 58470: FLUME-3084 : HDFS Sink - Provide ability to
roll the file with custom conditions.
-----------------------------------------------------------
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