code: @Private
    @Override
    public void aggregationThrewException(final List<Integer> taskletIds, final Exception exception) {
      try {
        failedTasklets(exception, taskletIds);
      } catch (final InterruptedException e) {
        throw new RuntimeException(e);
      }
    }
docs: A list of Tasklets has failed during aggregation phase.