client-tez/src/main/java/org/apache/tez/runtime/library/output/RssUnorderedPartitionedKVOutput.java [215:232]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public void start() throws Exception {
    if (!isStarted.get()) {
      memoryUpdateCallbackHandler.validateUpdateReceived();
      sorter =
          new RssUnSorter(
              taskAttemptId,
              getContext(),
              conf,
              mapNum,
              numOutputs,
              memoryUpdateCallbackHandler.getMemoryAssigned(),
              shuffleId,
              applicationAttemptId,
              partitionToServers);
      LOG.info("Initialized RssUnSorter.");
      isStarted.set(true);
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



client-tez/src/main/java/org/apache/tez/runtime/library/output/RssUnorderedKVOutput.java [217:234]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public void start() throws Exception {
    if (!isStarted.get()) {
      memoryUpdateCallbackHandler.validateUpdateReceived();
      sorter =
          new RssUnSorter(
              taskAttemptId,
              getContext(),
              conf,
              mapNum,
              numOutputs,
              memoryUpdateCallbackHandler.getMemoryAssigned(),
              shuffleId,
              applicationAttemptId,
              partitionToServers);
      LOG.info("Initialized RssUnSorter.");
      isStarted.set(true);
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -