Skip to content

Commit 652a7b6

Browse files
committed
Fix docs, space, and switch statement
1 parent 71f2174 commit 652a7b6

File tree

3 files changed

+10
-10
lines changed

3 files changed

+10
-10
lines changed

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/logaggregation/LogAggregationService.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -402,6 +402,7 @@ public void handle(LogHandlerEvent event) {
402402
LogHandlerContainerRecoveredEvent containerRecoveredEvent =
403403
(LogHandlerContainerRecoveredEvent) event;
404404
recoverContainer(containerRecoveredEvent.getContainerId());
405+
break;
405406
case LOG_AGG_TOKEN_UPDATE:
406407
checkAndEnableAppAggregators();
407408
break;

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/recovery/NMStateStoreService.java

Lines changed: 8 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -733,24 +733,23 @@ public abstract void removeLogDeleter(ApplicationId appId)
733733
/**
734734
* Load the state of the log aggregators
735735
* @return recovered log aggregator state
736-
* @throws IOException
736+
* @throws IOException if fails
737737
*/
738738
public abstract RecoveredLogAggregatorState loadLogAggregatorState()
739739
throws IOException;
740740

741741
/**
742-
* Store the state of a log deleter
743-
* @param appId the application ID for the log deleter
744-
* @param proto the serialized state of the log deleter
745-
* @throws IOException
742+
* Store the state of a log aggregator
743+
* @param containerId the container ID for the log aggregator
744+
* @throws IOException if fails
746745
*/
747-
public abstract void storeLogAggregator(ContainerId containerId)
746+
public abstract void storeLogAggregator(ContainerId containerId)
748747
throws IOException;
749748

750749
/**
751-
* Remove the state of a log deleter
752-
* @param appId the application ID for the log deleter
753-
* @throws IOException
750+
* Remove the state of a log aggregator
751+
* @param containerId the container ID for the log aggregator
752+
* @throws IOException if fails
754753
*/
755754
public abstract void removeLogAggregator(ContainerId containerId)
756755
throws IOException;

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/TestNodeStatusUpdater.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -964,7 +964,7 @@ public void testRecentlyFinishedContainers() throws Exception {
964964
nm.getNMContext().getContainers().putIfAbsent(cId, mock(Container.class));
965965

966966
nodeStatusUpdater.addCompletedContainer(cId);
967-
assertTrue(nodeStatusUpdater.isContainerRecentlyStopped(cId));
967+
assertTrue(nodeStatusUpdater.isContainerRecentlyStopped(cId));
968968
}
969969

970970
@Test

0 commit comments

Comments
 (0)