@Override
          public void afterFailure(Throwable t) {
            processorListenerState.put(ListenerCallback.AFTER_FAILURE, true);
            actualThrowable.getAndSet(t);
            processorListenerFailed.countDown();
          }
Tests that a failure in container correctly stops a running JobCoordinator and propagates the exception
through the StreamProcessor

Assertions:
- JobCoordinator has been stopped from the JobCoordinatorListener callback
- ProcessorLifecycleListener#afterStop(Throwable) has been invoked w/ non-null Throwable
samza-core/src/test/java/org/apache/samza/processor/TestStreamProcessor.java