[ 
https://issues.apache.org/jira/browse/FLUME-2007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13710465#comment-13710465
 ] 

Hudson commented on FLUME-2007:
-------------------------------

FAILURE: Integrated in flume-trunk #476 (See 
[https://builds.apache.org/job/flume-trunk/476/])
FLUME-2007. HDFS Sink should check if file is closed and retry if it is not. 
(hshreedharan: 
http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=5b5470bd5d3e94842032009c36788d4ae346674b)
* 
flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSSequenceFile.java
* 
flume-ng-sinks/flume-hdfs-sink/src/test/java/org/apache/flume/sink/hdfs/MockFsDataOutputStreamCloseRetryWrapper.java
* 
flume-ng-sinks/flume-hdfs-sink/src/test/java/org/apache/flume/sink/hdfs/TestUseRawLocalFileSystem.java
* 
flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/AbstractHDFSWriter.java
* 
flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSDataStream.java
* 
flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSCompressedDataStream.java
* 
flume-ng-sinks/flume-hdfs-sink/src/test/java/org/apache/flume/sink/hdfs/MockFileSystemCloseRetryWrapper.java

                
> HDFS Sink should check if file is closed and retry if it is not.
> ----------------------------------------------------------------
>
>                 Key: FLUME-2007
>                 URL: https://issues.apache.org/jira/browse/FLUME-2007
>             Project: Flume
>          Issue Type: Bug
>            Reporter: Hari Shreedharan
>            Assignee: Ted Malaska
>         Attachments: FLUME-2007-0.patch, FLUME-2007-1.patch, 
> FLUME-2007-2.patch, FLUME-2007-4.patch, FLUME-2007-5.patch, 
> FLUME-2007-6.patch, FLUME-2007-6.patch, FLUME-2007-7.patch, FLUME-2007-8.patch
>
>
> We can use the new API added in HDFS-4525. We will need to use reflection 
> though, so we can run against a version of HDFS which does not have this API.

--
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

Reply via email to