Home
last modified time | relevance | path

Searched refs:attempt1 (Results 1 – 25 of 28) sorted by relevance

12

/dports/net/concourse-fly/concourse-6.7.1/atc/exec/
H A Dretry_step_test.go19 attempt1 *execfakes.FakeStep
32 attempt1 = new(execfakes.FakeStep)
40 step = Retry(attempt1, attempt2, attempt3)
66 attempt1.SucceededReturns(true)
89 attempt1.SucceededReturns(true)
101 attempt1.SucceededReturns(false)
137 attempt1.RunReturns(errors.New("nope"))
173 attempt1.RunReturns(errors.New("nope"))
253 attempt1.SucceededReturns(false)
292 attempt1.SucceededReturns(false)
[all …]
/dports/misc/concourse/concourse-6.7.2/atc/exec/
H A Dretry_step_test.go19 attempt1 *execfakes.FakeStep
32 attempt1 = new(execfakes.FakeStep)
40 step = Retry(attempt1, attempt2, attempt3)
66 attempt1.SucceededReturns(true)
89 attempt1.SucceededReturns(true)
101 attempt1.SucceededReturns(false)
137 attempt1.RunReturns(errors.New("nope"))
173 attempt1.RunReturns(errors.New("nope"))
253 attempt1.SucceededReturns(false)
292 attempt1.SucceededReturns(false)
[all …]
/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/scheduler/
H A DTaskSchedulerImplSuite.scala175 taskScheduler.submitTasks(attempt1)
179 taskScheduler.taskSetManagerForAttempt(attempt1.stageId, attempt1.stageAttemptId)
195 val attempt1 = FakeTask.createTaskSet(10) constant
198 taskScheduler.submitTasks(attempt1)
203 taskScheduler.taskSetManagerForAttempt(attempt1.stageId, attempt1.stageAttemptId)
230 taskScheduler.submitTasks(attempt1)
235 val mgr1 = taskScheduler.taskSetManagerForAttempt(attempt1.stageId, attempt1.stageAttemptId).get
266 val attempt1 = FakeTask.createTaskSet(1) constant
269 taskScheduler.submitTasks(attempt1)
431 taskScheduler.submitTasks(attempt1)
[all …]
/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/
H A DTestApplicationMasterService.java83 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testRMIdentifierOnContainerAllocation() local
84 MockAM am1 = rm.sendAMLaunched(attempt1.getAppAttemptId()); in testRMIdentifierOnContainerAllocation()
123 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testInvalidContainerReleaseRequest() local
179 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testProgressFilter() local
191 while(attempt1.getProgress()!=1){ in testProgressFilter()
198 while(attempt1.getProgress()!=0){ in testProgressFilter()
205 while(attempt1.getProgress()!=1){ in testProgressFilter()
212 while(attempt1.getProgress()!=0){ in testProgressFilter()
219 while(attempt1.getProgress()!=0.5){ in testProgressFilter()
226 while(attempt1.getProgress()!=0){ in testProgressFilter()
[all …]
H A DTestFifoScheduler.java121 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testAllocateContainerOnNodeWithoutOffSwitchSpecified() local
122 MockAM am1 = rm.sendAMLaunched(attempt1.getAppAttemptId()); in testAllocateContainerOnNodeWithoutOffSwitchSpecified()
153 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in test() local
154 MockAM am1 = rm.sendAMLaunched(attempt1.getAppAttemptId()); in test()
216 while (attempt1.getJustFinishedContainers().size() < 1 in test()
222 Assert.assertEquals(1, attempt1.getJustFinishedContainers().size()); in test()
272 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testMinimumAllocation() local
273 MockAM am1 = rm.sendAMLaunched(attempt1.getAppAttemptId()); in testMinimumAllocation()
539 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testResourceOverCommit() local
540 MockAM am1 = rm.sendAMLaunched(attempt1.getAppAttemptId()); in testResourceOverCommit()
[all …]
H A DTestRMRestart.java216 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testRMRestart() local
365 attempt1 = loadedApp1.getCurrentAppAttempt(); in testRMRestart()
366 attemptId1 = attempt1.getAppAttemptId(); in testRMRestart()
398 am1 = rm2.sendAMLaunched(attempt1.getAppAttemptId()); in testRMRestart()
1221 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testAppAttemptTokensRestoredOnRMRestart() local
1234 attempt1.getClientTokenMasterKey().getEncoded(); in testAppAttemptTokensRestoredOnRMRestart()
1256 attempt1.getClientTokenMasterKey(), in testAppAttemptTokensRestoredOnRMRestart()
1749 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testQueueMetricsOnRMRestart() local
1794 attempt1 = loadedApp1.getCurrentAppAttempt(); in testQueueMetricsOnRMRestart()
1795 attemptId1 = attempt1.getAppAttemptId(); in testQueueMetricsOnRMRestart()
[all …]
H A DTestRM.java457 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testActivatingApplicationAfterAddingNM() local
458 ApplicationAttemptId attemptId1 = attempt1.getAppAttemptId(); in testActivatingApplicationAfterAddingNM()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/security/
H A DTestNMTokenSecretManagerInNM.java50 final ApplicationAttemptId attempt1 = in testRecovery() local
64 getNMTokenId(secretMgr.createNMToken(attempt1, nodeId, "user1")); in testRecovery()
69 assertTrue(secretMgr.isAppAttemptNMTokenKeyPresent(attempt1)); in testRecovery()
79 assertTrue(secretMgr.isAppAttemptNMTokenKeyPresent(attempt1)); in testRecovery()
87 secretMgr.appFinished(attempt1.getApplicationId()); in testRecovery()
94 assertFalse(secretMgr.isAppAttemptNMTokenKeyPresent(attempt1)); in testRecovery()
107 assertFalse(secretMgr.isAppAttemptNMTokenKeyPresent(attempt1)); in testRecovery()
123 assertFalse(secretMgr.isAppAttemptNMTokenKeyPresent(attempt1)); in testRecovery()
/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/applicationsmanager/
H A DTestAMRMRPCNodeUpdates.java134 RMAppAttempt attempt1 = app1.getCurrentAppAttempt();
135 MockAM am1 = rm.sendAMLaunched(attempt1.getAppAttemptId());
144 allocate(attempt1.getAppAttemptId(), allocateRequest1);
154 response1 = allocate(attempt1.getAppAttemptId(), allocateRequest1);
162 response1 = allocate(attempt1.getAppAttemptId(), allocateRequest1);
175 response1 = allocate(attempt1.getAppAttemptId(), allocateRequest1);
206 response1 = allocate(attempt1.getAppAttemptId(), allocateRequest1);
H A DTestAMRestart.java377 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testShouldNotCountFailureToMaxAttemptRetry() local
387 Assert.assertTrue(! attempt1.shouldCountTowardsMaxAttemptRetry()); in testShouldNotCountFailureToMaxAttemptRetry()
487 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testPreemptedAMRestartOnRMRestart() local
498 Assert.assertTrue(! attempt1.shouldCountTowardsMaxAttemptRetry()); in testPreemptedAMRestartOnRMRestart()
556 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testRMRestartOrFailoverNotCountedForAMFailures() local
557 Assert.assertTrue(((RMAppAttemptImpl) attempt1).mayBeLastAttempt()); in testRMRestartOrFailoverNotCountedForAMFailures()
569 status.setContainerId(attempt1.getMasterContainer().getId()); in testRMRestartOrFailoverNotCountedForAMFailures()
574 rm2.waitForState(attempt1.getAppAttemptId(), RMAppAttemptState.FAILED); in testRMRestartOrFailoverNotCountedForAMFailures()
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapred/
H A DTestTaskLogsTruncater.java388 TaskAttemptID attempt1 = new TaskAttemptID(baseTaskID, attemptsCount++); in testLogTruncationOnFinishingWithJVMReuse() local
389 Task task1 = new MapTask(null, attempt1, 0, new JobSplit.TaskSplitIndex(), in testLogTruncationOnFinishingWithJVMReuse()
393 writeRealChars(attempt1, attempt1, LogName.SYSLOG, 200, 'A'); in testLogTruncationOnFinishingWithJVMReuse()
395 File attemptDir = TaskLog.getAttemptDir(attempt1, false); in testLogTruncationOnFinishingWithJVMReuse()
403 writeRealChars(attempt1, attempt2, LogName.SYSLOG, 100, 'B'); in testLogTruncationOnFinishingWithJVMReuse()
409 writeRealChars(attempt1, attempt3, LogName.SYSLOG, 225, 'C'); in testLogTruncationOnFinishingWithJVMReuse()
417 File logFile = TaskLog.getTaskLogFile(attempt1, false, LogName.SYSLOG); in testLogTruncationOnFinishingWithJVMReuse()
420 assertEquals(150 + truncatedMsgSize, getAllLogsFileLengths(attempt1, false) in testLogTruncationOnFinishingWithJVMReuse()
429 attempt1, false); in testLogTruncationOnFinishingWithJVMReuse()
/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/deploy/history/
H A DApplicationCacheSuite.scala391 val attempt1 = Some("01") constant
401 operations.putAppUI(appId, attempt1, true, t, t, t)
405 cache.get(id, attempt1)
420 val attempt1 = Some("01") constant
423 operations.putAppUI(appId, attempt1, true, 100, 110, 110)
437 cache.get(appId, attempt1)
H A DFsHistoryProviderSuite.scala203 val attempt1 = newLogFile("app1", Some("attempt1"), inProgress = true) constant
204 writeFile(attempt1, true, None,
238 writeFile(attempt1, true, None,
/dports/textproc/jalingo/jalingo-0.6.0-src/src/ja/lingo/application/gui/main/describer/
H A DDescriberGui.java234 …int attempt1 = forwardDirection ? editorPane.getSelectionEnd() : editorPane.getSelectionStart() - … in find() local
237 …int index = TextSearcher.indexOf( forwardDirection, article, searchText, attempt1, caseSensetive, … in find()
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/mysql-test/suite/x/t/
H A Dsystem_variable_enable_hello_notice.test25 newsession attempt1 -;
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/mysql-test/suite/x/r/
H A Dsystem_variable_enable_hello_notice.result19 active session is now 'attempt1'
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/recovery/
H A DTestNMLeveldbStateStoreService.java727 ApplicationAttemptId attempt1 = ApplicationAttemptId.newInstance( in testNMTokenStorage() local
730 stateStore.storeNMTokenApplicationMasterKey(attempt1, attemptKey1); in testNMTokenStorage()
742 assertEquals(attemptKey1, loadedAppKeys.get(attempt1)); in testNMTokenStorage()
750 stateStore.removeNMTokenApplicationMasterKey(attempt1); in testNMTokenStorage()
763 assertNull(loadedAppKeys.get(attempt1)); in testNMTokenStorage()
/dports/www/moodle310/moodle/mod/h5pactivity/tests/local/
H A Dattempt_test.php218 $attempt1 = $this->generate_full_attempt($student, $cm);
232 attempt::delete_attempt($attempt1);
/dports/www/moodle311/moodle/mod/h5pactivity/tests/local/
H A Dattempt_test.php218 $attempt1 = $this->generate_full_attempt($student, $cm);
232 attempt::delete_attempt($attempt1);
/dports/www/moodle39/moodle/mod/h5pactivity/tests/local/
H A Dattempt_test.php218 $attempt1 = $this->generate_full_attempt($student, $cm);
232 attempt::delete_attempt($attempt1);
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/api/impl/
H A DTestAHSClient.java355 ApplicationAttemptReport attempt1 = in createAppReports() local
366 appAttempts.add(attempt1); in createAppReports()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/
H A DTestFileOutputCommitter.java73 private static final String attempt1 = "attempt_200707121733_0001_m_000001_0"; field in TestFileOutputCommitter
74 private static final TaskAttemptID taskID1 = TaskAttemptID.forName(attempt1);
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/repl/
H A Dinitial_syncer_test.cpp4037 BSONObj attempt1 = attempts["1"].Obj(); in TEST_F() local
4038 ASSERT_EQUALS(attempt1.nFields(), 3) << attempt1; in TEST_F()
4039 ASSERT_EQUALS(attempt1.getStringField("status"), std::string("OK")) << attempt1; in TEST_F()
4040 ASSERT_EQUALS(attempt1["durationMillis"].type(), NumberInt) << attempt1; in TEST_F()
4041 ASSERT_EQUALS(attempt1.getStringField("syncSource"), std::string("localhost:27017")) in TEST_F()
4042 << attempt1; in TEST_F()
/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/scheduler/capacity/
H A DTestCapacityScheduler.java696 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testResourceOverCommit() local
697 MockAM am1 = rm.sendAMLaunched(attempt1.getAppAttemptId()); in testResourceOverCommit()
751 while (attempt1.getJustFinishedContainers().size() < 1 in testResourceOverCommit()
757 Assert.assertEquals(1, attempt1.getJustFinishedContainers().size()); in testResourceOverCommit()
2077 RMAppAttempt attempt1 = app1.getCurrentAppAttempt();
2078 MockAM am1 = rm.sendAMLaunched(attempt1.getAppAttemptId());
2097 attempt1.getAppAttemptId());
2110 attempt1.getAppAttemptId());
H A DTestContainerAllocation.java115 RMAppAttempt attempt1 = app1.getCurrentAppAttempt(); in testExcessReservationThanNodeManagerCapacity() local
116 MockAM am1 = rm.sendAMLaunched(attempt1.getAppAttemptId()); in testExcessReservationThanNodeManagerCapacity()

12