incubator-crunch-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gr...@apache.org
Subject git commit: CRUNCH-138 Correct filesystem in getSequentialFileName
Date Wed, 02 Jan 2013 19:28:51 GMT
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 <greid@apache.org>
Authored: Wed Jan 2 20:27:14 2013 +0100
Committer: Gabriel Reid <greid@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);


Mime
View raw message