Author: mattf Date: Mon Oct 1 03:21:26 2012 New Revision: 1392180 URL: http://svn.apache.org/viewvc?rev=1392180&view=rev Log: reverting -r1392179, missed a needed line in the changelist
Modified: hadoop/common/branches/branch-1.1/src/mapred/org/apache/hadoop/mapred/IFileInputStream.java Modified: hadoop/common/branches/branch-1.1/src/mapred/org/apache/hadoop/mapred/IFileInputStream.java URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-1.1/src/mapred/org/apache/hadoop/mapred/IFileInputStream.java?rev=1392180&r1=1392179&r2=1392180&view=diff ============================================================================== --- hadoop/common/branches/branch-1.1/src/mapred/org/apache/hadoop/mapred/IFileInputStream.java (original) +++ hadoop/common/branches/branch-1.1/src/mapred/org/apache/hadoop/mapred/IFileInputStream.java Mon Oct 1 03:21:26 2012 @@ -101,7 +101,9 @@ class IFileInputStream extends InputStre private static FileDescriptor getFileDescriptorIfAvail(InputStream in) { FileDescriptor fd = null; try { - if (in instanceof FileInputStream) { + if (in instanceof HasFileDescriptor) { + fd = ((HasFileDescriptor)in).getFileDescriptor(); + } else if (in instanceof FileInputStream) { fd = ((FileInputStream)in).getFD(); } } catch (IOException e) {