@Override
          public void afterFailure(Throwable t) {
            afterFailureException.set(t);
          }
Given that the job model expires, but the container takes too long to stop, a TimeoutException should be propagated
to the processor lifecycle listener.
samza-core/src/test/java/org/apache/samza/processor/TestStreamProcessor.java