You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by su...@apache.org on 2020/03/09 12:22:38 UTC
[incubator-iotdb] branch master updated: [IOTDB-545] Update
checkPathValidity in Session (#895)
This is an automated email from the ASF dual-hosted git repository.
sunzesong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 59e7977 [IOTDB-545] Update checkPathValidity in Session (#895)
59e7977 is described below
commit 59e79774ea274bd8d3e5452670e05c3b4e904db4
Author: Zesong Sun <sz...@mails.tsinghua.edu.cn>
AuthorDate: Mon Mar 9 20:22:33 2020 +0800
[IOTDB-545] Update checkPathValidity in Session (#895)
---
.../main/java/org/apache/iotdb/hadoop/fileSystem/HDFSConfUtil.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSConfUtil.java b/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSConfUtil.java
index df0189b..bddf1f6 100644
--- a/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSConfUtil.java
+++ b/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSConfUtil.java
@@ -19,7 +19,6 @@
package org.apache.iotdb.hadoop.fileSystem;
-
import java.io.File;
import java.io.IOException;
import java.net.MalformedURLException;
@@ -27,6 +26,7 @@ import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.security.UserGroupInformation;
import org.apache.iotdb.tsfile.common.conf.TSFileConfig;
import org.apache.iotdb.tsfile.common.conf.TSFileDescriptor;
+import org.apache.iotdb.tsfile.fileSystem.FSType;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -36,6 +36,9 @@ class HDFSConfUtil {
private static final Logger logger = LoggerFactory.getLogger(HDFSConfUtil.class);
static Configuration setConf(Configuration conf) {
+ if (!tsFileConfig.getTSFileStorageFs().equals(FSType.HDFS)) {
+ return conf;
+ }
try {
conf.addResource(new File(tsFileConfig.getCoreSitePath()).toURI().toURL());
conf.addResource(new File(tsFileConfig.getHdfsSitePath()).toURI().toURL());