code: @Private
    @Override
    public void threwException(final int taskletId, final Exception exception) {
      try {
        failedTasklets(exception, Collections.singletonList(taskletId));
      } catch (final InterruptedException e) {
        throw new RuntimeException(e);
      }
    }
docs: A Tasklet associated with the aggregation has failed.