Now that we have a way to propagate an Exception to the iterator for partitions, we should also do this if an exception is found in any thread that processes data for the iterator.