diff --git a/tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezChild.java b/tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezChild.java index c0d0e7dfac..7ab532ad33 100644 --- a/tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezChild.java +++ b/tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezChild.java @@ -74,6 +74,7 @@ import org.apache.tez.runtime.common.objectregistry.ObjectRegistryImpl; import org.apache.tez.runtime.internals.api.TaskReporterInterface; import org.apache.tez.util.LoggingUtils; + import org.apache.tez.util.TezRuntimeShutdownHandler; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -252,10 +253,10 @@ public ContainerExecutionResult run() throws IOException, InterruptedException, TezTaskRunner2.mergeTaskSpecConfToConf(containerTask.getTaskSpec(), copy); LoggingUtils.initLoggingContext(mdcContext, copy, - attemptId.getTaskID().getVertexID().getDAGId().toString(), attemptId.toString()); + attemptId.getTaskID().getVertexID().getDAGID().toString(), attemptId.toString()); } else { LoggingUtils.initLoggingContext(mdcContext, defaultConf, - attemptId.getTaskID().getVertexID().getDAGId().toString(), attemptId.toString()); + attemptId.getTaskID().getVertexID().getDAGID().toString(), attemptId.toString()); } TezCommonUtils.logCredentials(LOG, containerTask.getCredentials(), "containerTask");