diff --git spark-client/src/main/java/org/apache/hive/spark/client/SparkClientUtilities.java spark-client/src/main/java/org/apache/hive/spark/client/SparkClientUtilities.java index 6251861..c9e1e43 100644 --- spark-client/src/main/java/org/apache/hive/spark/client/SparkClientUtilities.java +++ spark-client/src/main/java/org/apache/hive/spark/client/SparkClientUtilities.java @@ -83,7 +83,7 @@ private static URL urlFromPathString(String path, Long timeStamp, try { if (StringUtils.indexOf(path, "file:/") == 0) { url = new URL(path); - } else if (StringUtils.indexOf(path, "hdfs:/") == 0) { + } else if (StringUtils.indexOf(path, "hdfs:/") == 0 || StringUtils.indexOf(path, "viewfs:/") == 0) { Path remoteFile = new Path(path); Path localFile = new Path(localTmpDir.getAbsolutePath() + File.separator + remoteFile.getName());