Repository: hadoop
Updated Branches:
  refs/heads/branch-3.1 84531ad9b -> e343be46f


HADOOP-14970. MiniHadoopClusterManager doesn't respect lack of format option. 
Contributed by Erik Krogen

(cherry picked from commit 1a407bc9906306801690bc75ff0f0456f8f265fd)

Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/e343be46
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/e343be46
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/e343be46

Branch: refs/heads/branch-3.1
Commit: e343be46f8aa0cabe25d85e24c1e1ec8e6ebb061
Parents: 84531ad
Author: Erik Krogen <ekro...@linkedin.com>
Authored: Thu Apr 12 23:27:51 2018 -0700
Committer: Konstantin V Shvachko <s...@apache.org>
Committed: Thu Apr 12 23:31:18 2018 -0700

----------------------------------------------------------------------
 .../java/org/apache/hadoop/mapreduce/MiniHadoopClusterManager.java  | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hadoop/blob/e343be46/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce/MiniHadoopClusterManager.java
----------------------------------------------------------------------
diff --git 
a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce/MiniHadoopClusterManager.java
 
b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce/MiniHadoopClusterManager.java
index b89cdc0..d29dd34 100644
--- 
a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce/MiniHadoopClusterManager.java
+++ 
b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce/MiniHadoopClusterManager.java
@@ -156,6 +156,7 @@ public class MiniHadoopClusterManager {
     if (!noDFS) {
       dfs = new MiniDFSCluster.Builder(conf).nameNodePort(nnPort)
           .nameNodeHttpPort(nnHttpPort).numDataNodes(numDataNodes)
+          .format(dfsOpts == StartupOption.FORMAT)
           .startupOption(dfsOpts).build();
       LOG.info("Started MiniDFSCluster -- namenode on port "
           + dfs.getNameNodePort());


---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org

Reply via email to