本文整理了Java中org.apache.hadoop.yarn.event.AsyncDispatcher.stop()方法的一些代码示例，展示了AsyncDispatcher.stop()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。AsyncDispatcher.stop()方法的具体详情如下：
包路径：org.apache.hadoop.yarn.event.AsyncDispatcher
类名称：AsyncDispatcher
方法名：stop

AsyncDispatcher.stop介绍

暂无

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-common

protected void stopDispatcher() {
 AsyncDispatcher asyncDispatcher = (AsyncDispatcher) dispatcher;
 if (null != asyncDispatcher) {
  asyncDispatcher.stop();
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-common

protected void stopDispatcher() {
 AsyncDispatcher asyncDispatcher = (AsyncDispatcher) dispatcher;
 asyncDispatcher.stop();
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

protected void stopDispatcher() {
 AsyncDispatcher asyncDispatcher = (AsyncDispatcher) dispatcher;
 if (null != asyncDispatcher) {
  asyncDispatcher.stop();
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-common

protected void stopDispatcher() {
 AsyncDispatcher asyncDispatcher = (AsyncDispatcher) dispatcher;
 asyncDispatcher.stop();
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

@Override
protected void serviceStop() throws Exception {
 dispatcher.stop();
 closeInternal();
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

@Override
protected void serviceStop() throws Exception {
 dispatcher.stop();
 closeInternal();
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Override
protected void serviceStop() throws Exception {
 dispatcher.stop();
 closeInternal();
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

@After
public void tearDown() throws Exception {
 ((AsyncDispatcher)this.spyRMContext.getDispatcher()).stop();
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@After
public void tearDown() throws Exception {
 ((AsyncDispatcher)this.spyRMContext.getDispatcher()).stop();
}

代码示例来源：origin: apache/tajo

@AfterClass
public static void tearDown() {
 util.shutdownCatalogCluster();
 if (dispatcher != null) {
  dispatcher.stop();
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

@Test(timeout=20000)
public void testRebootedDuringCommit() throws Exception {
 Configuration conf = new Configuration();
 conf.set(MRJobConfig.MR_AM_STAGING_DIR, stagingDir);
 conf.setInt(MRJobConfig.MR_AM_MAX_ATTEMPTS, 2);
 AsyncDispatcher dispatcher = new AsyncDispatcher();
 dispatcher.init(conf);
 dispatcher.start();
 CyclicBarrier syncBarrier = new CyclicBarrier(2);
 OutputCommitter committer = new WaitingOutputCommitter(syncBarrier, true);
 CommitterEventHandler commitHandler =
   createCommitterEventHandler(dispatcher, committer);
 commitHandler.init(conf);
 commitHandler.start();
 AppContext mockContext = mock(AppContext.class);
 when(mockContext.isLastAMRetry()).thenReturn(true);
 when(mockContext.hasSuccessfullyUnregistered()).thenReturn(false);
 JobImpl job = createRunningStubbedJob(conf, dispatcher, 2, mockContext);
 completeJobTasks(job);
 assertJobState(job, JobStateInternal.COMMITTING);
 syncBarrier.await();
 job.handle(new JobEvent(job.getID(), JobEventType.JOB_AM_REBOOT));
 assertJobState(job, JobStateInternal.REBOOT);
 // return the external state as ERROR since this is last retry.
 Assert.assertEquals(JobState.RUNNING, job.getState());
 when(mockContext.hasSuccessfullyUnregistered()).thenReturn(true);
 Assert.assertEquals(JobState.ERROR, job.getState());
 dispatcher.stop();
 commitHandler.stop();
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

@Test(timeout=20000)
public void testCommitJobFailsJob() throws Exception {
 Configuration conf = new Configuration();
 conf.set(MRJobConfig.MR_AM_STAGING_DIR, stagingDir);
 AsyncDispatcher dispatcher = new AsyncDispatcher();
 dispatcher.init(conf);
 dispatcher.start();
 CyclicBarrier syncBarrier = new CyclicBarrier(2);
 OutputCommitter committer = new TestingOutputCommitter(syncBarrier, false);
 CommitterEventHandler commitHandler =
   createCommitterEventHandler(dispatcher, committer);
 commitHandler.init(conf);
 commitHandler.start();
 JobImpl job = createRunningStubbedJob(conf, dispatcher, 2, null);
 completeJobTasks(job);
 assertJobState(job, JobStateInternal.COMMITTING);
 // let the committer fail and verify the job fails
 syncBarrier.await();
 assertJobState(job, JobStateInternal.FAILED);
 dispatcher.stop();
 commitHandler.stop();
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

job.handle(new JobStartEvent(job.getID()));
assertJobState(job, JobStateInternal.SUCCEEDED);
dispatcher.stop();
commitHandler.stop();
try {

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

@Test(timeout=20000)
public void testKilledDuringCommit() throws Exception {
 Configuration conf = new Configuration();
 conf.set(MRJobConfig.MR_AM_STAGING_DIR, stagingDir);
 AsyncDispatcher dispatcher = new AsyncDispatcher();
 dispatcher.init(conf);
 dispatcher.start();
 CyclicBarrier syncBarrier = new CyclicBarrier(2);
 OutputCommitter committer = new WaitingOutputCommitter(syncBarrier, true);
 CommitterEventHandler commitHandler =
   createCommitterEventHandler(dispatcher, committer);
 commitHandler.init(conf);
 commitHandler.start();
 JobImpl job = createRunningStubbedJob(conf, dispatcher, 2, null);
 completeJobTasks(job);
 assertJobState(job, JobStateInternal.COMMITTING);
 syncBarrier.await();
 job.handle(new JobEvent(job.getID(), JobEventType.JOB_KILL));
 assertJobState(job, JobStateInternal.KILLED);
 dispatcher.stop();
 commitHandler.stop();
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

} finally {
 schedulerDispatcher.stop();
 rmDispatcher.stop();

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

Assert.assertEquals(JobState.FAILED, job.getState());
dispatcher.stop();
commitHandler.stop();

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

dispatcher.stop();
commitHandler.stop();

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

dispatcher.stop();
commitHandler.stop();

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

assertJobState(job, JobStateInternal.SUCCEEDED);
dispatcher.stop();
commitHandler.stop();

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

dispatcher.stop();
commitHandler.stop();