manually apply patch for YARN-2985

palantir · Mar 21, 2021 · ce34626 · ce34626
1 parent 7a3bc90
commit ce34626
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...ava/org/apache/hadoop/yarn/server/applicationhistoryservice/ApplicationHistoryServer.java b/...ava/org/apache/hadoop/yarn/server/applicationhistoryservice/ApplicationHistoryServer.java
@@ -41,6 +41,7 @@
 import org.apache.hadoop.yarn.YarnUncaughtExceptionHandler;
 import org.apache.hadoop.yarn.conf.YarnConfiguration;
 import org.apache.hadoop.yarn.exceptions.YarnRuntimeException;
+import org.apache.hadoop.yarn.logaggregation.AggregatedLogDeletionService;
 import org.apache.hadoop.yarn.server.applicationhistoryservice.webapp.AHSWebApp;
 import org.apache.hadoop.yarn.server.security.ApplicationACLsManager;
 import org.apache.hadoop.yarn.server.timeline.LeveldbTimelineStore;
@@ -70,6 +71,7 @@ public class ApplicationHistoryServer extends CompositeService {
   private static final Logger LOG = LoggerFactory
       .getLogger(ApplicationHistoryServer.class);
 
+  private AggregatedLogDeletionService aggregatedLogDeletionService;
   private ApplicationHistoryClientService ahsClientService;
   private ApplicationACLsManager aclsManager;
   private ApplicationHistoryManager historyManager;
@@ -99,6 +101,8 @@ protected void serviceInit(Configuration conf) throws Exception {
     addService(secretManagerService);
     timelineDataManager = createTimelineDataManager(conf);
     addService(timelineDataManager);
+    aggregatedLogDeletionService = new AggregatedLogDeletionService();
+    addService(aggregatedLogDeletionService);
 
     // init generic history service afterwards
     aclsManager = createApplicationACLsManager(conf);