Examples of org.apache.hadoop.yarn.event.DrainDispatcher.stop()

Class org.apache.hadoop.yarn.event.DrainDispatcher

Examples of org.apache.hadoop.yarn.event.DrainDispatcher.stop()

org.apache.hadoop.yarn.event.DrainDispatcher.stop()

        
      // Verify deletion of localization token.
      verify(delService).delete((String)isNull(), eq(localizationTokenPath));
    } finally {
      spyService.stop();
      dispatcher.stop();
      delService.stop();
    }
  }


  @Test(timeout=20000)

View Full Code Here

      // allow the chmod to fail now that both requests have been queued
      barrier.await();
      verify(containerBus, timeout(5000).times(2))
          .handle(isA(ContainerResourceFailedEvent.class));
    } finally {
      dispatcher.stop();
    }
  }
  
  /*
   * Test case for handling RejectedExecutionException and IOException which can

View Full Code Here


    } finally {
      // if we call stop with events in the queue, an InterruptedException gets
      // thrown resulting in the dispatcher thread causing a system exit
      dispatcher.await();
      dispatcher.stop();
    }
  }


  @Test(timeout = 100000)
  @SuppressWarnings("unchecked")

View Full Code Here

      Assert.assertEquals(0, localizerRunner2.pending.size());
      Assert.assertEquals(0, response2.getResourceSpecs().size());


    } finally {
      if (dispatcher1 != null) {
        dispatcher1.stop();
      }
    }
  }

View Full Code Here

      }
      // We should receive both the resources (Application and Private)
      Assert.assertTrue(appRsrc && privRsrc);
    } finally {
      if (dispatcher1 != null) {
        dispatcher1.stop();
      }
    }
  }


  private LocalizerStatus createLocalizerStatusForFailedResource(

View Full Code Here

      // Checking available permits now.
      Assert.assertEquals(1, lr.sem.availablePermits());


    } finally {
      if (dispatcher1 != null) {
        dispatcher1.stop();
      }
    }


  }

View Full Code Here

            appAttemptId.getApplicationId(),
            ApplicationEventType.APPLICATION_LOG_HANDLING_FINISHED)
    };


    checkEvents(appEventHandler, expectedEvents, true, "getType", "getApplicationID");
    dispatcher.stop();
  }


  @Test
  @SuppressWarnings("unchecked")
  public void testNoContainerOnNode() throws Exception {

View Full Code Here

        new ApplicationEvent(
            application1,
            ApplicationEventType.APPLICATION_LOG_HANDLING_FINISHED)
    };
    checkEvents(appEventHandler, expectedEvents, true, "getType", "getApplicationID");
    dispatcher.stop();
  }


  @Test
  @SuppressWarnings("unchecked")
  public void testMultipleAppsLogAggregation() throws Exception {

View Full Code Here

        new ApplicationEvent(
            application3,
            ApplicationEventType.APPLICATION_LOG_HANDLING_FINISHED)
    };
    checkEvents(appEventHandler, expectedFinishedEvents, false, "getType", "getApplicationID");
    dispatcher.stop();
  }
  
  @Test
  @SuppressWarnings("unchecked")
  public void testLogAggregationInitFailsWithoutKillingNM() throws Exception {

View Full Code Here

        new ContainerEventMatcher(container4,
            ContainerEventType.RESOURCE_LOCALIZED);
      verify(containerBus).handle(argThat(matchesC4Localized));
      assertEquals(ResourceState.LOCALIZED, local.getState());
    } finally {
      dispatcher.stop();
    }
  }


  @Test
  public void testDirectLocalization() throws Exception {

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.