Updated Branches: refs/heads/master 867314ef6 -> 67142f6b4
CRUNCH-52: Explicitly reference the file that we want to read in with the output records. Project: http://git-wip-us.apache.org/repos/asf/incubator-crunch/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-crunch/commit/67142f6b Tree: http://git-wip-us.apache.org/repos/asf/incubator-crunch/tree/67142f6b Diff: http://git-wip-us.apache.org/repos/asf/incubator-crunch/diff/67142f6b Branch: refs/heads/master Commit: 67142f6b4fb8c258297ad2230090ea9d5c4f12c5 Parents: 867314e Author: Josh Wills <[email protected]> Authored: Sat Sep 8 18:56:35 2012 -0700 Committer: Josh Wills <[email protected]> Committed: Sat Sep 8 18:56:35 2012 -0700 ---------------------------------------------------------------------- .../org/apache/crunch/io/avro/AvroPipelineIT.java | 7 +------ 1 files changed, 1 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/67142f6b/crunch/src/it/java/org/apache/crunch/io/avro/AvroPipelineIT.java ---------------------------------------------------------------------- diff --git a/crunch/src/it/java/org/apache/crunch/io/avro/AvroPipelineIT.java b/crunch/src/it/java/org/apache/crunch/io/avro/AvroPipelineIT.java index 22892ec..e0a7ead 100644 --- a/crunch/src/it/java/org/apache/crunch/io/avro/AvroPipelineIT.java +++ b/crunch/src/it/java/org/apache/crunch/io/avro/AvroPipelineIT.java @@ -90,12 +90,7 @@ public class AvroPipelineIT implements Serializable { pipeline.write(genericCollection, textFile); pipeline.run(); Person person = genericCollection.materialize().iterator().next(); - Collection<File> listFiles = FileUtils.listFiles(outputFile, null, false); - File partFile = null; - for (File foundfile : listFiles) { - partFile = foundfile; - } - String outputString = FileUtils.readFileToString(partFile); + String outputString = FileUtils.readFileToString(new File(outputFile, "part-m-00000")); assertTrue(outputString.contains(person.toString())); } }
