    @Test
    public void testNotTooManyErrors() throws Exception {

        ErrorHandler errHandler = getErrorHandler();
        BaseTask.StreamMetrics metrics = new BaseTask.StreamMetrics(new Meter(clock), new Meter(clock));

        when(clock.getTick()).thenReturn(0L);
        metrics.processed.mark(910L);
        metrics.dropped.mark(90L);

        when(clock.getTick()).thenReturn(TimeUnit.SECONDS.toNanos(10));
        assertTrue(metrics.processed.getOneMinuteRate() > 0);
        assertTrue(metrics.dropped.getOneMinuteRate() > 0);
        assertFalse(errHandler.hasTooManyErrors(metrics));
    }