| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/event/ |
| H A D | AppAttemptAddedSchedulerEvent.java | 26 private final boolean transferStateFromPreviousAttempt; field in AppAttemptAddedSchedulerEvent
31 boolean transferStateFromPreviousAttempt) { in AppAttemptAddedSchedulerEvent() argument
32 this(applicationAttemptId, transferStateFromPreviousAttempt, false); in AppAttemptAddedSchedulerEvent()
37 boolean transferStateFromPreviousAttempt, in AppAttemptAddedSchedulerEvent() argument
41 this.transferStateFromPreviousAttempt = transferStateFromPreviousAttempt; in AppAttemptAddedSchedulerEvent()
50 return transferStateFromPreviousAttempt; in getTransferStateFromPreviousAttempt()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/attempt/ |
| H A D | RMAppStartAttemptEvent.java | 25 private final boolean transferStateFromPreviousAttempt; field in RMAppStartAttemptEvent
28 boolean transferStateFromPreviousAttempt) { in RMAppStartAttemptEvent() argument
30 this.transferStateFromPreviousAttempt = transferStateFromPreviousAttempt; in RMAppStartAttemptEvent()
34 return transferStateFromPreviousAttempt; in getTransferStateFromPreviousAttempt()
|
| H A D | RMAppAttemptImpl.java | 851 public void transferStateFromPreviousAttempt(RMAppAttempt attempt) { in transferStateFromPreviousAttempt() method in RMAppAttemptImpl
893 boolean transferStateFromPreviousAttempt = false; in transition()
895 transferStateFromPreviousAttempt = in transition()
914 appAttempt.applicationAttemptId, transferStateFromPreviousAttempt)); in transition()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/ |
| H A D | RMAppFailedAttemptEvent.java | 25 private final boolean transferStateFromPreviousAttempt; field in RMAppFailedAttemptEvent
28 String diagnostics, boolean transferStateFromPreviousAttempt) { in RMAppFailedAttemptEvent() argument
30 this.transferStateFromPreviousAttempt = transferStateFromPreviousAttempt; in RMAppFailedAttemptEvent()
34 return transferStateFromPreviousAttempt; in getTransferStateFromPreviousAttempt()
|
| H A D | RMAppImpl.java | 758 createAndStartNewAttempt(boolean transferStateFromPreviousAttempt) { in createAndStartNewAttempt() argument
761 transferStateFromPreviousAttempt)); in createAndStartNewAttempt()
1211 boolean transferStateFromPreviousAttempt; in transition()
1213 transferStateFromPreviousAttempt = in transition()
1217 app.createAndStartNewAttempt(transferStateFromPreviousAttempt); in transition()
1225 .transferStateFromPreviousAttempt(oldAttempt); in transition()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/attempt/ |
| H A D | TestRMAppAttemptTransitions.java | 164 private boolean transferStateFromPreviousAttempt = false; field in TestRMAppAttemptTransitions
190 transferStateFromPreviousAttempt = in handle()
446 assertFalse(transferStateFromPreviousAttempt); in testAppAttemptKilledState()
606 assertFalse(transferStateFromPreviousAttempt); in testAppAttemptFinishedState()
742 assertFalse(transferStateFromPreviousAttempt); in testUnmanagedAMSuccess()
827 assertFalse(transferStateFromPreviousAttempt); in testUnmanagedAMContainersCleanup()
1455 assertTrue(transferStateFromPreviousAttempt); in testFailedToFailed()
1505 assertFalse(transferStateFromPreviousAttempt); in testContainersCleanupForLastAttempt()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/common/fica/ |
| H A D | FiCaSchedulerApp.java | 326 public synchronized void transferStateFromPreviousAttempt( in transferStateFromPreviousAttempt() method in FiCaSchedulerApp
328 super.transferStateFromPreviousAttempt(appAttempt); in transferStateFromPreviousAttempt()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fifo/ |
| H A D | FifoScheduler.java | 380 boolean transferStateFromPreviousAttempt, in addApplicationAttempt() argument
390 if (transferStateFromPreviousAttempt) { in addApplicationAttempt()
391 schedulerApp.transferStateFromPreviousAttempt(application in addApplicationAttempt()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/ |
| H A D | FairScheduler.java | 644 boolean transferStateFromPreviousAttempt, in addApplicationAttempt() argument
655 if (transferStateFromPreviousAttempt) { in addApplicationAttempt()
656 attempt.transferStateFromPreviousAttempt(application in addApplicationAttempt()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/ |
| H A D | CapacityScheduler.java | 822 boolean transferStateFromPreviousAttempt, in addApplicationAttempt() argument
836 if (transferStateFromPreviousAttempt) { in addApplicationAttempt()
837 attempt.transferStateFromPreviousAttempt(application in addApplicationAttempt()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/ |
| H A D | SchedulerApplicationAttempt.java | 571 public synchronized void transferStateFromPreviousAttempt( in transferStateFromPreviousAttempt() method in SchedulerApplicationAttempt
|