diff --git ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java index 540bafd..92870c5 100644 --- ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java +++ ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java @@ -1224,10 +1224,10 @@ private static String getURLType(String value) throws URISyntaxException { String scheme = uri.getScheme() == null ? null : uri.getScheme().toLowerCase(); if (scheme == null || scheme.equals("file")) { return "file"; - } else if (scheme.equals("hdfs") || scheme.equals("ivy")) { + } else if (scheme.equals("hdfs") || scheme.equals("ivy") || scheme.equals("viewfs")) { return scheme; } else { - throw new RuntimeException("invalid url: " + uri + ", expecting ( file | hdfs | ivy) as url scheme. "); + throw new RuntimeException("invalid url: " + uri + ", expecting ( file | hdfs | ivy | viewfs) as url scheme. "); } } @@ -1238,7 +1238,7 @@ private static String getURLType(String value) throws URISyntaxException { return Arrays.asList(uri); } else if (getURLType(value).equals("ivy")) { return dependencyResolver.downloadDependencies(uri); - } else if (getURLType(value).equals("hdfs")) { + } else if (getURLType(value).equals("hdfs") || getURLType(value).equals("viewfs")) { return Arrays.asList(createURI(downloadResource(value, convertToUnix))); } else { throw new RuntimeException("Invalid url " + uri);