diff --git a/src/java/org/apache/sqoop/mapreduce/AvroInputFormat.java b/src/java/org/apache/sqoop/mapreduce/AvroInputFormat.java
index 0d5c08e9..81cca174 100644
--- a/src/java/org/apache/sqoop/mapreduce/AvroInputFormat.java
+++ b/src/java/org/apache/sqoop/mapreduce/AvroInputFormat.java
@@ -34,18 +34,6 @@
 public class AvroInputFormat<T>
   extends FileInputFormat<AvroWrapper<T>, NullWritable> {
 
-  @Override
-  protected List<FileStatus> listStatus(JobContext job) throws IOException {
-    List<FileStatus> result = new ArrayList<FileStatus>();
-    for (FileStatus file : super.listStatus(job)) {
-      if (file.getPath().getName().endsWith(
-          org.apache.avro.mapred.AvroOutputFormat.EXT)) {
-        result.add(file);
-      }
-    }
-    return result;
-  }
-
   @Override
   public RecordReader<AvroWrapper<T>, NullWritable> createRecordReader(
       InputSplit split, TaskAttemptContext context) throws IOException,
diff --git a/src/test/com/cloudera/sqoop/TestAvroExport.java b/src/test/com/cloudera/sqoop/TestAvroExport.java
index 70168263..db776e65 100644
--- a/src/test/com/cloudera/sqoop/TestAvroExport.java
+++ b/src/test/com/cloudera/sqoop/TestAvroExport.java
@@ -126,9 +126,8 @@ public Schema getColumnAvroSchema() {
   protected void createAvroFile(int fileNum, int numRecords,
       ColumnGenerator... extraCols) throws IOException {
 
-    String ext = ".avro";
     Path tablePath = getTablePath();
-    Path filePath = new Path(tablePath, "part" + fileNum + ext);
+    Path filePath = new Path(tablePath, "part" + fileNum);
 
     Configuration conf = new Configuration();
     if (!BaseSqoopTestCase.isOnPhysicalCluster()) {