client-tez/tez/src/main/java/org/apache/tez/runtime/library/output/CelebornUnorderedPartitionedKVOutput.java [117:145]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public synchronized void start() throws Exception {
    if (!isStarted.get()) {
      memoryUpdateCallbackHandler.validateUpdateReceived();
      CelebornConf celebornConf = CelebornTezUtils.fromTezConfiguration(conf);
      CelebornTezWriter celebornTezWriter =
          new CelebornTezWriter(
              shuffleId,
              mapId,
              mapId,
              attemptId,
              numMapppers,
              numOutputs,
              celebornConf,
              appId,
              host,
              port,
              new UserIdentifier(
                  celebornConf.userSpecificTenant(), celebornConf.userSpecificUserName()));
      this.kvWriter =
          new CelebornUnorderedPartitionedKVWriter(
              getContext(),
              conf,
              numOutputs,
              memoryUpdateCallbackHandler.getMemoryAssigned(),
              celebornTezWriter,
              celebornConf);
      isStarted.set(true);
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



client-tez/tez/src/main/java/org/apache/tez/runtime/library/output/CelebornUnorderedKVOutput.java [127:155]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public synchronized void start() throws Exception {
    if (!isStarted.get()) {
      memoryUpdateCallbackHandler.validateUpdateReceived();
      CelebornConf celebornConf = CelebornTezUtils.fromTezConfiguration(conf);
      CelebornTezWriter celebornTezWriter =
          new CelebornTezWriter(
              shuffleId,
              mapId,
              mapId,
              attemptId,
              numMapppers,
              numOutputs,
              celebornConf,
              appId,
              host,
              port,
              new UserIdentifier(
                  celebornConf.userSpecificTenant(), celebornConf.userSpecificUserName()));
      this.kvWriter =
          new CelebornUnorderedPartitionedKVWriter(
              getContext(),
              conf,
              numOutputs,
              memoryUpdateCallbackHandler.getMemoryAssigned(),
              celebornTezWriter,
              celebornConf);
      isStarted.set(true);
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -