diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java index abbf38f..82efa72 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java @@ -627,9 +627,6 @@ public Path getDefaultDestDir(Configuration conf) throws LoginException, IOExcep String userPathStr = HiveConf.getVar(conf, HiveConf.ConfVars.HIVE_USER_INSTALL_DIR); Path userPath = new Path(userPathStr); FileSystem fs = userPath.getFileSystem(conf); - if (!(fs instanceof DistributedFileSystem)) { - throw new IOException(ErrorMsg.INVALID_HDFS_URI.format(userPathStr)); - } String jarPathStr = userPathStr + "/" + userName; String hdfsDirPathStr = jarPathStr; @@ -738,9 +735,6 @@ public FileStatus getHiveJarDirectory(Configuration conf) throws IOException, Lo public static FileStatus validateTargetDir(Path path, Configuration conf) throws IOException { FileSystem fs = path.getFileSystem(conf); - if (!(fs instanceof DistributedFileSystem)) { - throw new IOException(ErrorMsg.INVALID_HDFS_URI.format(path.toString())); - } FileStatus fstatus = null; try { fstatus = fs.getFileStatus(path); @@ -798,9 +792,6 @@ private boolean checkPreExisting(Path src, Path dest, Configuration conf) public LocalResource localizeResource(Path src, Path dest, Configuration conf) throws IOException { FileSystem destFS = dest.getFileSystem(conf); - if (!(destFS instanceof DistributedFileSystem)) { - throw new IOException(ErrorMsg.INVALID_HDFS_URI.format(dest.toString())); - } if (src != null) { // copy the src to the destination and create local resource.