You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by Alexandre Dutra <al...@gmail.com> on 2013/12/30 17:43:19 UTC
Review Request 16517: [FLUME-2215] ResettableFileInputStream can't support
ucs-4 character (alternate patch)
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/16517/
-----------------------------------------------------------
Review request for Flume.
Repository: flume-git
Description
-------
See https://issues.apache.org/jira/browse/FLUME-2215 for details.
Please note that I am actually proposing two different patches to fix this issue. Reviewers please test them separately.
Diffs
-----
flume-ng-core/src/main/java/org/apache/flume/client/avro/ReliableSpoolingFileEventReader.java a88ed6e
flume-ng-core/src/main/java/org/apache/flume/serialization/AvroEventDeserializer.java e44978f
flume-ng-core/src/main/java/org/apache/flume/serialization/DecodeErrorPolicy.java a55b6b6
flume-ng-core/src/main/java/org/apache/flume/serialization/EventDeserializer.java bbb3375
flume-ng-core/src/main/java/org/apache/flume/serialization/EventDeserializerFactory.java 80b9cc3
flume-ng-core/src/main/java/org/apache/flume/serialization/EventSerDe.java fb1663a
flume-ng-core/src/main/java/org/apache/flume/serialization/LengthMeasurable.java bc6647f
flume-ng-core/src/main/java/org/apache/flume/serialization/LineDeserializer.java d8e5ae2
flume-ng-core/src/main/java/org/apache/flume/serialization/RemoteMarkable.java 774152e
flume-ng-core/src/main/java/org/apache/flume/serialization/ResettableFileInputStream.java 587ab29
flume-ng-core/src/main/java/org/apache/flume/serialization/ResettableInputStream.java ddebc30
flume-ng-core/src/main/java/org/apache/flume/serialization/ResettableInputStreamReader.java PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/serialization/ResettableLineReader.java PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/serialization/Seekable.java 513f29a
flume-ng-core/src/main/java/org/apache/flume/serialization/SeekableBufferedFileInputStream.java PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/serialization/SeekableBufferedInputStream.java PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/serialization/SeekableFileInputStream.java PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/serialization/SeekableInputStream.java PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/serialization/SeekableReliableInputStream.java PRE-CREATION
flume-ng-core/src/main/java/org/apache/flume/source/SpoolDirectorySource.java f42ed2d
flume-ng-core/src/main/java/org/apache/flume/source/SpoolDirectorySourceConfigurationConstants.java 83522c0
flume-ng-core/src/test/java/org/apache/flume/serialization/ResettableTestStringInputStream.java 03c8dda
flume-ng-core/src/test/java/org/apache/flume/serialization/SeekableBufferedByteArrayInputStream.java PRE-CREATION
flume-ng-core/src/test/java/org/apache/flume/serialization/SeekableByteArrayInputStream.java PRE-CREATION
flume-ng-core/src/test/java/org/apache/flume/serialization/TestAvroEventDeserializer.java 6f9ddc2
flume-ng-core/src/test/java/org/apache/flume/serialization/TestDecodeErrorPolicy.java PRE-CREATION
flume-ng-core/src/test/java/org/apache/flume/serialization/TestLineDeserializer.java 1a0d561
flume-ng-core/src/test/java/org/apache/flume/serialization/TestResettableFileInputStream.java 73df9c9
flume-ng-core/src/test/java/org/apache/flume/serialization/TestResettableInputStreamReader.java PRE-CREATION
flume-ng-core/src/test/java/org/apache/flume/serialization/TestResettableLineReader.java PRE-CREATION
flume-ng-core/src/test/java/org/apache/flume/serialization/TestSeekableBufferedByteArrayInputStream.java PRE-CREATION
flume-ng-core/src/test/java/org/apache/flume/serialization/TestSeekableBufferedFileInputStream.java PRE-CREATION
flume-ng-core/src/test/java/org/apache/flume/serialization/TestSeekableBufferedInputStream.java PRE-CREATION
flume-ng-core/src/test/java/org/apache/flume/serialization/TestSeekableByteArrayInputStream.java PRE-CREATION
flume-ng-core/src/test/java/org/apache/flume/serialization/TestSeekableFileInputStream.java PRE-CREATION
flume-ng-core/src/test/java/org/apache/flume/serialization/TestSeekableInputStream.java PRE-CREATION
flume-ng-core/src/test/java/org/apache/flume/serialization/TestSeekableReliableInputStream.java PRE-CREATION
flume-ng-doc/sphinx/FlumeUserGuide.rst a2790d9
flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/BlobDeserializer.java 12bdc40
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/ResettableTestStringInputStream.java e6ee9b9
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/SeekableByteArrayInputStream.java PRE-CREATION
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestBlobDeserializer.java 6172c68
Diff: https://reviews.apache.org/r/16517/diff/
Testing
-------
Thanks,
Alexandre Dutra