@Test
public void testNumInputFilesWithoutRecursively() throws Exception {

  Configuration conf = getConfiguration();
  conf.setInt(FileInputFormat.LIST_STATUS_NUM_THREADS, numThreads);
  Job job = Job.getInstance(conf);
  FileInputFormat<?, ?> fileInputFormat = new TextInputFormat();
  List<InputSplit> splits = fileInputFormat.getSplits(job);
  Assert.assertEquals("Input splits are not correct", 2, splits.size());
  verifySplits(Lists.newArrayList("test:/a1/a2", "test:/a1/file1"), splits);
}