hadoop-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Arshad Ali Sayed <arshad.ali.sayed...@gmail.com>
Subject Facing Issues in FTPFileSystem class
Date Tue, 28 Jul 2015 11:30:45 GMT
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)

Mime
View raw message