You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by xk...@apache.org on 2019/08/22 16:57:18 UTC
[hadoop] branch trunk updated: HDFS-14755. [Dynamometer] Enhance
compatibility of Dynamometer with branch-2 builds. Contributed by Takanobu
Asanuma.
This is an automated email from the ASF dual-hosted git repository.
xkrogen pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 63c295e HDFS-14755. [Dynamometer] Enhance compatibility of Dynamometer with branch-2 builds. Contributed by Takanobu Asanuma.
63c295e is described below
commit 63c295e29840587eb6eb4a0fa258c55002e3229a
Author: Erik Krogen <xk...@apache.org>
AuthorDate: Thu Aug 22 09:57:00 2019 -0700
HDFS-14755. [Dynamometer] Enhance compatibility of Dynamometer with branch-2 builds. Contributed by Takanobu Asanuma.
---
.../org/apache/hadoop/tools/dynamometer/SimulatedDataNodes.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
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 8def3ff..520077e 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 class SimulatedDataNodes extends Configured implements Tool {
}
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);
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org