getting StreamClosed exception every time I read file from FTP server

[Arshad Ali Sayed]

I am using Hfs Tap to read file from FTP Server. Its running fine in hadoop. but while using cascading I am facing issues.

I am Providing path (i.e. url) along with credentials in the format ftp://username:password@host/directory/file.

getting following Exception every time and hence unable to read file.

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)

[Andre Kelpe]

This is a hadoop or environment problem. Please ask on the Hadoop mailing list.

- André

--
You received this message because you are subscribed to the Google Groups "cascading-user" group.
To unsubscribe from this group and stop receiving emails from it, send an email to cascading-use...@googlegroups.com.
To post to this group, send email to cascadi...@googlegroups.com.
Visit this group at http://groups.google.com/group/cascading-user.
To view this discussion on the web visit https://groups.google.com/d/msgid/cascading-user/ebde6a9b-504b-4450-b930-9f3eeeb630c1%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

--

André Kelpe
an...@concurrentinc.com
http://concurrentinc.com

[Arshad Ali Sayed]

Ok. Thanks Andre.

[Arshad Ali Sayed]

I have checked it with Map Reduce program. It is running fine and I am able to read file from FTP Server. But while executing it with Cascading, it doesn't works.