|
@@ -151,11 +151,14 @@ public class MiniMRYarnCluster extends MiniYARNCluster {
|
|
if (!getConfig().getBoolean(
|
|
if (!getConfig().getBoolean(
|
|
JHAdminConfig.MR_HISTORY_MINICLUSTER_FIXED_PORTS,
|
|
JHAdminConfig.MR_HISTORY_MINICLUSTER_FIXED_PORTS,
|
|
JHAdminConfig.DEFAULT_MR_HISTORY_MINICLUSTER_FIXED_PORTS)) {
|
|
JHAdminConfig.DEFAULT_MR_HISTORY_MINICLUSTER_FIXED_PORTS)) {
|
|
|
|
+ String hostname = MiniYARNCluster.getHostname();
|
|
// pick free random ports.
|
|
// pick free random ports.
|
|
getConfig().set(JHAdminConfig.MR_HISTORY_ADDRESS,
|
|
getConfig().set(JHAdminConfig.MR_HISTORY_ADDRESS,
|
|
- MiniYARNCluster.getHostname() + ":0");
|
|
|
|
|
|
+ hostname + ":0");
|
|
getConfig().set(JHAdminConfig.MR_HISTORY_WEBAPP_ADDRESS,
|
|
getConfig().set(JHAdminConfig.MR_HISTORY_WEBAPP_ADDRESS,
|
|
- MiniYARNCluster.getHostname() + ":0");
|
|
|
|
|
|
+ hostname + ":0");
|
|
|
|
+ getConfig().set(JHAdminConfig.JHS_ADMIN_ADDRESS,
|
|
|
|
+ hostname + ":0");
|
|
}
|
|
}
|
|
historyServer = new JobHistoryServer();
|
|
historyServer = new JobHistoryServer();
|
|
historyServer.init(getConfig());
|
|
historyServer.init(getConfig());
|