diff --git a/hadoop-hdds/framework/src/main/java/org/apache/hadoop/hdds/server/ServerUtils.java b/hadoop-hdds/framework/src/main/java/org/apache/hadoop/hdds/server/ServerUtils.java index 33a1ca9558b..f775ca104b3 100644 --- a/hadoop-hdds/framework/src/main/java/org/apache/hadoop/hdds/server/ServerUtils.java +++ b/hadoop-hdds/framework/src/main/java/org/apache/hadoop/hdds/server/ServerUtils.java @@ -203,25 +203,4 @@ public static void setOzoneMetaDirPath(OzoneConfiguration conf, conf.set(HddsConfigKeys.OZONE_METADATA_DIRS, path); } - /** - * Returns with the service specific metadata directory. - *
- * If the directory is missing the method tries to create it.
- *
- * @param conf The ozone configuration object
- * @param key The configuration key which specify the directory.
- * @return The path of the directory.
- */
- public static File getDBPath(Configuration conf, String key) {
- final File dbDirPath =
- getDirectoryFromConfig(conf, key, "OM");
- if (dbDirPath != null) {
- return dbDirPath;
- }
-
- LOG.warn("{} is not configured. We recommend adding this setting. "
- + "Falling back to {} instead.", key,
- HddsConfigKeys.OZONE_METADATA_DIRS);
- return ServerUtils.getOzoneMetaDirPath(conf);
- }
}
diff --git a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ScmUtils.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ScmUtils.java
index 426341a32f4..37702532ac7 100644
--- a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ScmUtils.java
+++ b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ScmUtils.java
@@ -18,13 +18,18 @@
package org.apache.hadoop.hdds.scm;
-import org.apache.hadoop.hdds.protocol.proto.HddsProtos.ScmOps;
-import org.apache.hadoop.hdds.scm.exceptions.SCMException;
-import org.apache.hadoop.hdds.scm.safemode.Precheck;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hdds.HddsConfigKeys;
+import org.apache.hadoop.hdds.protocol.proto.HddsProtos.ScmOps;
+import org.apache.hadoop.hdds.scm.safemode.Precheck;
+import org.apache.hadoop.hdds.scm.exceptions.SCMException;
+import org.apache.hadoop.hdds.server.ServerUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import java.io.File;
+
/**
* SCM utility class.
*/
@@ -48,4 +53,16 @@ public static void preCheck(ScmOps operation, Precheck... preChecks)
}
}
+ public static File getDBPath(Configuration conf, String dbDirectory) {
+ final File dbDirPath =
+ ServerUtils.getDirectoryFromConfig(conf, dbDirectory, "OM");
+ if (dbDirPath != null) {
+ return dbDirPath;
+ }
+
+ LOG.warn("{} is not configured. We recommend adding this setting. "
+ + "Falling back to {} instead.", dbDirectory,
+ HddsConfigKeys.OZONE_METADATA_DIRS);
+ return ServerUtils.getOzoneMetaDirPath(conf);
+ }
}
diff --git a/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/scm/exceptions/SCMException.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/exceptions/SCMException.java
similarity index 100%
rename from hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/scm/exceptions/SCMException.java
rename to hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/exceptions/SCMException.java
diff --git a/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/scm/exceptions/package-info.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/exceptions/package-info.java
similarity index 100%
rename from hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/scm/exceptions/package-info.java
rename to hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/exceptions/package-info.java
diff --git a/hadoop-ozone/common/pom.xml b/hadoop-ozone/common/pom.xml
index 050022c9495..06973b39753 100644
--- a/hadoop-ozone/common/pom.xml
+++ b/hadoop-ozone/common/pom.xml
@@ -60,6 +60,10 @@ https://maven.apache.org/xsd/maven-4.0.0.xsd">