You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@crunch.apache.org by jw...@apache.org on 2016/12/03 19:57:14 UTC
crunch git commit: CRUNCH-622: From.avroFile fails if path not on
default filesystem. Contributed by Micah Whitacre.
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 <jw...@apache.org>
Authored: Sat Dec 3 11:56:59 2016 -0800
Committer: Josh Wills <jw...@apache.org>
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