client-spark/spark2/src/main/java/org/apache/spark/shuffle/writer/RssShuffleWriter.java [189:216]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public RssShuffleWriter(
      String appId,
      int shuffleId,
      String taskId,
      long taskAttemptId,
      ShuffleWriteMetrics shuffleWriteMetrics,
      RssShuffleManager shuffleManager,
      SparkConf sparkConf,
      ShuffleWriteClient shuffleWriteClient,
      Supplier<ShuffleManagerClient> managerClientSupplier,
      RssShuffleHandle<K, V, C> rssHandle,
      Function<String, Boolean> taskFailureCallback,
      TaskContext context) {
    this(
        appId,
        shuffleId,
        taskId,
        taskAttemptId,
        shuffleWriteMetrics,
        shuffleManager,
        sparkConf,
        shuffleWriteClient,
        managerClientSupplier,
        rssHandle,
        taskFailureCallback,
        shuffleManager.getShuffleHandleInfo(
            context.stageId(), context.stageAttemptNumber(), rssHandle, true),
        context);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



client-spark/spark3/src/main/java/org/apache/spark/shuffle/writer/RssShuffleWriter.java [264:291]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public RssShuffleWriter(
      String appId,
      int shuffleId,
      String taskId,
      long taskAttemptId,
      ShuffleWriteMetrics shuffleWriteMetrics,
      RssShuffleManager shuffleManager,
      SparkConf sparkConf,
      ShuffleWriteClient shuffleWriteClient,
      Supplier<ShuffleManagerClient> managerClientSupplier,
      RssShuffleHandle<K, V, C> rssHandle,
      Function<String, Boolean> taskFailureCallback,
      TaskContext context) {
    this(
        appId,
        shuffleId,
        taskId,
        taskAttemptId,
        shuffleWriteMetrics,
        shuffleManager,
        sparkConf,
        shuffleWriteClient,
        managerClientSupplier,
        rssHandle,
        taskFailureCallback,
        shuffleManager.getShuffleHandleInfo(
            context.stageId(), context.stageAttemptNumber(), rssHandle, true),
        context);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -