[
https://issues.apache.org/jira/browse/FLUME-1632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13536739#comment-13536739
]
Hudson commented on FLUME-1632:
-------------------------------
Integrated in flume-trunk #344 (See
[https://builds.apache.org/job/flume-trunk/344/])
FLUME-1632: Persist progress on each file in file spooling client/source
(Revision fad7251dbc13e74bb070691e7a5b643f2402b901)
Result = SUCCESS
brock :
http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=fad7251dbc13e74bb070691e7a5b643f2402b901
Files :
*
flume-ng-core/src/main/java/org/apache/flume/serialization/EventSerializer.java
* flume-ng-core/src/main/avro/TransferStateFileMeta.avsc
*
flume-ng-core/src/test/java/org/apache/flume/source/TestSpoolDirectorySource.java
*
flume-ng-core/src/test/resources/TestResettableFileInputStream_1.truncated.avro
*
flume-ng-core/src/main/java/org/apache/flume/client/avro/SimpleTextLineEventReader.java
*
flume-ng-core/src/test/java/org/apache/flume/serialization/ResettableTestStringInputStream.java
*
flume-ng-core/src/main/java/org/apache/flume/serialization/DurablePositionTracker.java
*
flume-ng-core/src/test/java/org/apache/flume/serialization/TestLineDeserializer.java
*
flume-ng-core/src/test/java/org/apache/flume/client/avro/TestBufferedLineReader.java
*
flume-ng-core/src/test/java/org/apache/flume/serialization/TestReliableSpoolingFileEventReader.java
*
flume-ng-core/src/main/java/org/apache/flume/serialization/ResettableInputStream.java
*
flume-ng-core/src/main/java/org/apache/flume/client/avro/ReliableEventReader.java
*
flume-ng-core/src/test/java/org/apache/flume/serialization/TestResettableFileInputStream.java
*
flume-ng-core/src/main/java/org/apache/flume/serialization/ResettableFileInputStream.java
* flume-ng-core/src/main/java/org/apache/flume/client/avro/LineReader.java
*
flume-ng-core/src/main/java/org/apache/flume/serialization/EventSerializerType.java
*
flume-ng-core/src/main/java/org/apache/flume/client/avro/BufferedLineReader.java
*
flume-ng-core/src/main/java/org/apache/flume/serialization/LineDeserializer.java
* flume-ng-core/src/main/java/org/apache/flume/tools/PlatformDetect.java
* flume-ng-core/src/main/java/org/apache/flume/source/SpoolDirectorySource.java
* flume-ng-core/src/test/resources/TestResettableFileInputStream_1.avro
* flume-ng-core/src/main/java/org/apache/flume/serialization/Resettable.java
*
flume-ng-core/src/main/java/org/apache/flume/source/SpoolDirectorySourceConfigurationConstants.java
*
flume-ng-core/src/main/java/org/apache/flume/serialization/PositionTracker.java
* flume-ng-core/src/main/java/org/apache/flume/client/avro/AvroCLIClient.java
*
flume-ng-core/src/main/java/org/apache/flume/serialization/EventDeserializer.java
*
flume-ng-core/src/main/java/org/apache/flume/client/avro/ReliableSpoolingFileEventReader.java
*
flume-ng-core/src/main/java/org/apache/flume/serialization/EventSerializerFactory.java
* flume-ng-core/src/main/java/org/apache/flume/serialization/EventSerDe.java
* pom.xml
*
flume-ng-core/src/test/java/org/apache/flume/serialization/TestDurablePositionTracker.java
*
flume-ng-core/src/main/java/org/apache/flume/serialization/EventDeserializerFactory.java
*
flume-ng-core/src/main/java/org/apache/flume/serialization/EventDeserializerType.java
*
flume-ng-core/src/test/java/org/apache/flume/client/avro/TestSpoolingFileLineReader.java
* flume-ng-core/src/main/java/org/apache/flume/client/avro/EventReader.java
* flume-ng-core/pom.xml
*
flume-ng-core/src/main/java/org/apache/flume/client/avro/SpoolingFileLineReader.java
> Persist progress on each file in file spooling client/source
> ------------------------------------------------------------
>
> Key: FLUME-1632
> URL: https://issues.apache.org/jira/browse/FLUME-1632
> Project: Flume
> Issue Type: New Feature
> Reporter: Mike Percy
> Assignee: Mike Percy
> Fix For: v1.4.0
>
> Attachments: FLUME-1632-10a.patch, FLUME-1632-11b.patch,
> FLUME-1632-7.patch, FLUME-1632-9b.patch
>
>
> Add the ability to persist progress on a partially consumed file in spooling
> client/source
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
