This is an automated email from the ASF dual-hosted git repository.
adoroszlai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new ee8dd8c30f HDDS-9804. ozone freon dfsg does not work with relative
--path (#5704)
ee8dd8c30f is described below
commit ee8dd8c30ffb830626a9dcffd53fcf73596004d9
Author: Wei-Chiu Chuang <[email protected]>
AuthorDate: Wed Dec 6 23:20:17 2023 -0800
HDDS-9804. ozone freon dfsg does not work with relative --path (#5704)
---
.../java/org/apache/hadoop/ozone/freon/HadoopFsGenerator.java | 10 +++++++---
1 file changed, 7 insertions(+), 3 deletions(-)
diff --git
a/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/HadoopFsGenerator.java
b/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/HadoopFsGenerator.java
index aced39c47b..dd386fb926 100644
---
a/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/HadoopFsGenerator.java
+++
b/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/HadoopFsGenerator.java
@@ -19,6 +19,7 @@ package org.apache.hadoop.ozone.freon;
import java.io.IOException;
import java.io.UncheckedIOException;
import java.net.URI;
+import java.util.Optional;
import java.util.concurrent.Callable;
import org.apache.hadoop.fs.FSDataOutputStream;
@@ -45,7 +46,7 @@ public class HadoopFsGenerator extends BaseFreonGenerator
implements Callable<Void> {
@Option(names = {"--path"},
- description = "Hadoop FS file system path",
+ description = "Hadoop FS file system path. Use full path.",
defaultValue = "o3fs://bucket1.vol1")
private String rootPath;
@@ -87,8 +88,11 @@ public class HadoopFsGenerator extends BaseFreonGenerator
configuration = createOzoneConfiguration();
uri = URI.create(rootPath);
- String disableCacheName = String.format("fs.%s.impl.disable.cache",
- uri.getScheme());
+ String scheme = Optional.ofNullable(uri.getScheme())
+ .orElseGet(() -> FileSystem.getDefaultUri(configuration)
+ .getScheme());
+ String disableCacheName =
+ String.format("fs.%s.impl.disable.cache", scheme);
print("Disabling FS cache: " + disableCacheName);
configuration.setBoolean(disableCacheName, true);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
