diff --git a/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/main/java/org/apache/hadoop/tools/dynamometer/SimulatedDataNodes.java b/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/main/java/org/apache/hadoop/tools/dynamometer/SimulatedDataNodes.java index 8def3ff06346e..520077e0823cb 100644 --- a/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/main/java/org/apache/hadoop/tools/dynamometer/SimulatedDataNodes.java +++ b/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/main/java/org/apache/hadoop/tools/dynamometer/SimulatedDataNodes.java @@ -109,8 +109,10 @@ public int run(String[] args) throws Exception { } System.out.println("DataNodes will connect to NameNode at " + nameNodeAdr); - System.setProperty(MiniDFSCluster.PROP_TEST_BUILD_DATA, - DataNode.getStorageLocations(getConf()).get(0).getUri().getPath()); + String loc = DataNode.getStorageLocations(getConf()).get(0).toString(); + loc = loc.substring(loc.indexOf("]") + 1); // delete storage type + String path = new URI(loc).getPath(); + System.setProperty(MiniDFSCluster.PROP_TEST_BUILD_DATA, path); SimulatedFSDataset.setFactory(getConf()); getConf().setLong(SimulatedFSDataset.CONFIG_PROPERTY_CAPACITY, STORAGE_CAPACITY);