You are viewing a plain text version of this content. The canonical link for it is here.

Posted to mapreduce-user@hadoop.apache.org by Arshad Ali Sayed <ar...@gmail.com> on 2015/07/28 13:30:45 UTC

Facing Issues in FTPFileSystem class

I am using Cascading on top of hadoop. where I am using a Tap which reads
data from FTP Server.

Internally map reduce program gets executed which uses FTPFileSystem class
to read data.

Every time I try to read file from FTP server it throws following (Stream
Closed) Error:


java.io.IOException: Stream closed
    at org.apache.hadoop.fs.ftp.FTPInputStream.close(FTPInputStream.java:96)
    at java.io.FilterInputStream.close(Unknown Source)
    at org.apache.hadoop.util.LineReader.close(LineReader.java:83)
    at
org.apache.hadoop.mapred.LineRecordReader.close(LineRecordReader.java:168)
    at
org.apache.hadoop.mapred.MapTask$TrackedRecordReader.close(MapTask.java:254)
    at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:440)
    at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
    at
org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)