client-spark/spark2/src/main/java/org/apache/spark/shuffle/writer/RssShuffleWriter.java [247:258]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public void write(Iterator<Product2<K, V>> records) {
    try {
      writeImpl(records);
    } catch (Exception e) {
      taskFailureCallback.apply(taskId);
      if (enableWriteFailureRetry) {
        throwFetchFailedIfNecessary(e, Sets.newConcurrentHashSet());
      } else {
        throw e;
      }
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



client-spark/spark3/src/main/java/org/apache/spark/shuffle/writer/RssShuffleWriter.java [320:331]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public void write(Iterator<Product2<K, V>> records) {
    try {
      writeImpl(records);
    } catch (Exception e) {
      taskFailureCallback.apply(taskId);
      if (enableWriteFailureRetry) {
        throwFetchFailedIfNecessary(e, Sets.newConcurrentHashSet());
      } else {
        throw e;
      }
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -