diff --git a/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java b/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java index d81b44c..515127c 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java @@ -555,8 +555,15 @@ private Path createRootHDFSDir(HiveConf conf) throws IOException { Utilities.createDirsWithPermission(conf, rootHDFSDirPath, writableHDFSDirPermission, true); } FsPermission currentHDFSDirPermission = fs.getFileStatus(rootHDFSDirPath).getPermission(); - LOG.debug("HDFS root scratch dir: " + rootHDFSDirPath + ", permission: " - + currentHDFSDirPermission); + if (rootHDFSDirPath != null && rootHDFSDirPath.toUri() != null) { + String schema = rootHDFSDirPath.toUri().getScheme(); + LOG.debug( + "HDFS root scratch dir: " + rootHDFSDirPath + " with schema " + schema + ", permission: " + + currentHDFSDirPermission); + } else { + LOG.debug( + "HDFS root scratch dir: " + rootHDFSDirPath + ", permission: " + currentHDFSDirPermission); + } // If the root HDFS scratch dir already exists, make sure it is writeable. if (!((currentHDFSDirPermission.toShort() & writableHDFSDirPermission .toShort()) == writableHDFSDirPermission.toShort())) {