|
@@ -27,6 +27,7 @@ import org.apache.hadoop.mapreduce.v2.MiniMRYarnCluster;
|
|
|
import org.apache.hadoop.yarn.api.records.timeline.TimelineEntities;
|
|
|
import org.apache.hadoop.yarn.api.records.timeline.TimelineEntity;
|
|
|
import org.apache.hadoop.yarn.conf.YarnConfiguration;
|
|
|
+import org.apache.hadoop.yarn.server.MiniYARNCluster;
|
|
|
import org.apache.hadoop.yarn.server.timeline.TimelineStore;
|
|
|
|
|
|
import org.junit.Assert;
|
|
@@ -91,6 +92,9 @@ public class TestMRTimelineEventHandling {
|
|
|
TestJobHistoryEventHandler.class.getSimpleName(), 1);
|
|
|
cluster.init(conf);
|
|
|
cluster.start();
|
|
|
+ conf.set(YarnConfiguration.TIMELINE_SERVICE_WEBAPP_ADDRESS,
|
|
|
+ MiniYARNCluster.getHostname() + ":"
|
|
|
+ + cluster.getApplicationHistoryServer().getPort());
|
|
|
TimelineStore ts = cluster.getApplicationHistoryServer()
|
|
|
.getTimelineStore();
|
|
|
|
|
@@ -145,6 +149,9 @@ public class TestMRTimelineEventHandling {
|
|
|
TestJobHistoryEventHandler.class.getSimpleName(), 1);
|
|
|
cluster.init(conf);
|
|
|
cluster.start();
|
|
|
+ conf.set(YarnConfiguration.TIMELINE_SERVICE_WEBAPP_ADDRESS,
|
|
|
+ MiniYARNCluster.getHostname() + ":"
|
|
|
+ + cluster.getApplicationHistoryServer().getPort());
|
|
|
TimelineStore ts = cluster.getApplicationHistoryServer()
|
|
|
.getTimelineStore();
|
|
|
|
|
@@ -182,6 +189,9 @@ public class TestMRTimelineEventHandling {
|
|
|
TestJobHistoryEventHandler.class.getSimpleName(), 1);
|
|
|
cluster.init(conf);
|
|
|
cluster.start();
|
|
|
+ conf.set(YarnConfiguration.TIMELINE_SERVICE_WEBAPP_ADDRESS,
|
|
|
+ MiniYARNCluster.getHostname() + ":"
|
|
|
+ + cluster.getApplicationHistoryServer().getPort());
|
|
|
TimelineStore ts = cluster.getApplicationHistoryServer()
|
|
|
.getTimelineStore();
|
|
|
|