Updated Branches: refs/heads/master c440ca5e2 -> 08fa84e59
CRUNCH-138 Correct filesystem in getSequentialFileName Correction for SequentialFileNamingScheme.getSequentialFileName. Contributed by Daithi O Crualaoich. Project: http://git-wip-us.apache.org/repos/asf/incubator-crunch/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-crunch/commit/08fa84e5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-crunch/tree/08fa84e5 Diff: http://git-wip-us.apache.org/repos/asf/incubator-crunch/diff/08fa84e5 Branch: refs/heads/master Commit: 08fa84e592d605a2b3d1465c031db3a64c76faf6 Parents: c440ca5 Author: Gabriel Reid <[email protected]> Authored: Wed Jan 2 20:27:14 2013 +0100 Committer: Gabriel Reid <[email protected]> Committed: Wed Jan 2 20:27:14 2013 +0100 ---------------------------------------------------------------------- .../crunch/io/SequentialFileNamingScheme.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/08fa84e5/crunch/src/main/java/org/apache/crunch/io/SequentialFileNamingScheme.java ---------------------------------------------------------------------- diff --git a/crunch/src/main/java/org/apache/crunch/io/SequentialFileNamingScheme.java b/crunch/src/main/java/org/apache/crunch/io/SequentialFileNamingScheme.java index 0b2affa..bdda8e6 100644 --- a/crunch/src/main/java/org/apache/crunch/io/SequentialFileNamingScheme.java +++ b/crunch/src/main/java/org/apache/crunch/io/SequentialFileNamingScheme.java @@ -42,7 +42,7 @@ public class SequentialFileNamingScheme implements FileNamingScheme { private String getSequentialFileName(Configuration configuration, Path outputDirectory, String jobTypeName) throws IOException { - FileSystem fileSystem = FileSystem.get(configuration); + FileSystem fileSystem = outputDirectory.getFileSystem(configuration); int fileSequenceNumber = fileSystem.listStatus(outputDirectory).length; return String.format("part-%s-%05d", jobTypeName, fileSequenceNumber);
