You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@crunch.apache.org by gr...@apache.org on 2013/01/02 20:28:51 UTC
git commit: CRUNCH-138 Correct filesystem in getSequentialFileName
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 <gr...@apache.org>
Authored: Wed Jan 2 20:27:14 2013 +0100
Committer: Gabriel Reid <gr...@apache.org>
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);