Updated Branches: refs/heads/master 4236ec7b7 -> a97e8e101
CRUNCH-220: Use the FileSystem implied by the target path in FileTargetImpl Project: http://git-wip-us.apache.org/repos/asf/crunch/repo Commit: http://git-wip-us.apache.org/repos/asf/crunch/commit/a97e8e10 Tree: http://git-wip-us.apache.org/repos/asf/crunch/tree/a97e8e10 Diff: http://git-wip-us.apache.org/repos/asf/crunch/diff/a97e8e10 Branch: refs/heads/master Commit: a97e8e1019334263b8f8b5aeaa9135345e466d2a Parents: 4236ec7 Author: Josh Wills <[email protected]> Authored: Wed Jun 19 12:45:55 2013 -0700 Committer: Josh Wills <[email protected]> Committed: Wed Jun 19 12:45:55 2013 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/crunch/io/impl/FileTargetImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/crunch/blob/a97e8e10/crunch-core/src/main/java/org/apache/crunch/io/impl/FileTargetImpl.java ---------------------------------------------------------------------- diff --git a/crunch-core/src/main/java/org/apache/crunch/io/impl/FileTargetImpl.java b/crunch-core/src/main/java/org/apache/crunch/io/impl/FileTargetImpl.java index ea424e7..4e3dd9a 100644 --- a/crunch-core/src/main/java/org/apache/crunch/io/impl/FileTargetImpl.java +++ b/crunch-core/src/main/java/org/apache/crunch/io/impl/FileTargetImpl.java @@ -90,7 +90,7 @@ public class FileTargetImpl implements PathTarget { FileSystem srcFs = workingPath.getFileSystem(conf); Path src = getSourcePattern(workingPath, index); Path[] srcs = FileUtil.stat2Paths(srcFs.globStatus(src), src); - FileSystem dstFs = FileSystem.get(conf); + FileSystem dstFs = path.getFileSystem(conf); if (!dstFs.exists(path)) { dstFs.mkdirs(path); }
