|
@@ -127,10 +127,14 @@ public class ApplicationHistoryServer extends CompositeService {
|
|
|
return this.ahsClientService;
|
|
|
}
|
|
|
|
|
|
+ private InetSocketAddress getListenerAddress() {
|
|
|
+ return this.webApp.httpServer().getConnectorAddress(0);
|
|
|
+ }
|
|
|
+
|
|
|
@Private
|
|
|
@VisibleForTesting
|
|
|
public int getPort() {
|
|
|
- return this.webApp.httpServer().getConnectorAddress(0).getPort();
|
|
|
+ return this.getListenerAddress().getPort();
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -278,6 +282,12 @@ public class ApplicationHistoryServer extends CompositeService {
|
|
|
ahsClientService, "ws")
|
|
|
.with(conf).at(bindAddress).start(
|
|
|
new AHSWebApp(timelineDataManager, ahsClientService));
|
|
|
+
|
|
|
+ conf.updateConnectAddr(YarnConfiguration.TIMELINE_SERVICE_BIND_HOST,
|
|
|
+ YarnConfiguration.TIMELINE_SERVICE_WEBAPP_ADDRESS,
|
|
|
+ YarnConfiguration.DEFAULT_TIMELINE_SERVICE_WEBAPP_ADDRESS,
|
|
|
+ this.getListenerAddress());
|
|
|
+ LOG.info("Instantiating AHSWebApp at " + getPort());
|
|
|
} catch (Exception e) {
|
|
|
String msg = "AHSWebApp failed to start.";
|
|
|
LOG.error(msg, e);
|