Repository: crunch Updated Branches: refs/heads/master fbda02f46 -> c14acfab0
CRUNCH-622: From.avroFile fails if path not on default filesystem. Contributed by Micah Whitacre. Project: http://git-wip-us.apache.org/repos/asf/crunch/repo Commit: http://git-wip-us.apache.org/repos/asf/crunch/commit/c14acfab Tree: http://git-wip-us.apache.org/repos/asf/crunch/tree/c14acfab Diff: http://git-wip-us.apache.org/repos/asf/crunch/diff/c14acfab Branch: refs/heads/master Commit: c14acfab04a18d7b57af040c9399ec0cca61eed6 Parents: fbda02f Author: Josh Wills <[email protected]> Authored: Sat Dec 3 11:56:59 2016 -0800 Committer: Josh Wills <[email protected]> Committed: Sat Dec 3 11:56:59 2016 -0800 ---------------------------------------------------------------------- crunch-core/src/main/java/org/apache/crunch/io/From.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/crunch/blob/c14acfab/crunch-core/src/main/java/org/apache/crunch/io/From.java ---------------------------------------------------------------------- diff --git a/crunch-core/src/main/java/org/apache/crunch/io/From.java b/crunch-core/src/main/java/org/apache/crunch/io/From.java index 37f08a4..f15f309 100644 --- a/crunch-core/src/main/java/org/apache/crunch/io/From.java +++ b/crunch-core/src/main/java/org/apache/crunch/io/From.java @@ -346,7 +346,7 @@ public class From { static Schema getSchemaFromPath(Path path, Configuration conf) { DataFileReader reader = null; try { - FileSystem fs = FileSystem.get(conf); + FileSystem fs = path.getFileSystem(conf); if (!fs.isFile(path)) { FileStatus[] fstat = fs.listStatus(path, new PathFilter() { @Override
