diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMAppImpl.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMAppImpl.java index ca88b8be3281c..9e458bcfe1d8f 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMAppImpl.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMAppImpl.java @@ -1018,14 +1018,14 @@ private void createNewAttempt(ApplicationAttemptId appAttemptId) { private void processNodeUpdate(RMAppNodeUpdateType type, RMNode node) { NodeState nodeState = node.getState(); updatedNodes.put(node, RMAppNodeUpdateType.convertToNodeUpdateType(type)); - LOG.debug("Received node update event:{} for node:{} with state:", + LOG.debug("Received node update event:{} for node:{} with state:{}.", type, node, nodeState); } private static class RMAppTransition implements SingleArcTransition { public void transition(RMAppImpl app, RMAppEvent event) { - }; + } } private static final class RMAppNodeUpdateTransition extends RMAppTransition { @@ -1033,7 +1033,7 @@ public void transition(RMAppImpl app, RMAppEvent event) { RMAppNodeUpdateEvent nodeUpdateEvent = (RMAppNodeUpdateEvent) event; app.processNodeUpdate(nodeUpdateEvent.getUpdateType(), nodeUpdateEvent.getNode()); - }; + } } private static final class RMAppStateUpdateTransition @@ -1047,7 +1047,7 @@ public RMAppStateUpdateTransition(YarnApplicationState state) { public void transition(RMAppImpl app, RMAppEvent event) { app.rmContext.getSystemMetricsPublisher().appStateUpdated( app, stateToATS, app.systemClock.getTime()); - }; + } } private static final class AttemptLaunchedTransition @@ -1189,7 +1189,7 @@ private static final class StartAppAttemptTransition extends RMAppTransition { @Override public void transition(RMAppImpl app, RMAppEvent event) { app.createAndStartNewAttempt(false); - }; + } } private static final class FinalStateSavedTransition implements @@ -1374,7 +1374,7 @@ public AppFinishedTransition() { public void transition(RMAppImpl app, RMAppEvent event) { app.diagnostics.append(event.getDiagnosticMsg()); super.transition(app, event); - }; + } } private static class AttemptFinishedAtFinalSavingTransition extends @@ -1393,7 +1393,7 @@ public void transition(RMAppImpl app, RMAppEvent event) { app.rememberTargetTransitions(event, new AppFinishedFinalStateSavedTransition(app.eventCausingFinalSaving), RMAppState.FINISHED); - }; + } } private static class AppFinishedFinalStateSavedTransition extends @@ -1407,7 +1407,7 @@ public AppFinishedFinalStateSavedTransition(RMAppEvent attemptUnregistered) { public void transition(RMAppImpl app, RMAppEvent event) { new AttemptUnregisteredTransition().transition(app, attemptUnregistered); FINISHED_TRANSITION.transition(app, event); - }; + } } /** @@ -1440,7 +1440,7 @@ public void transition(RMAppImpl app, RMAppEvent event) { app.diagnostics.append(event.getDiagnosticMsg()); super.transition(app, event); RMAppImpl.auditLogKillEvent(event); - }; + } } private static class KillAttemptTransition extends RMAppTransition { @@ -1465,7 +1465,7 @@ public AppRejectedTransition() { public void transition(RMAppImpl app, RMAppEvent event) { app.diagnostics.append(event.getDiagnosticMsg()); super.transition(app, event); - }; + } } /**