From db0ac9e09eb3168312c87271c04870fe7d2fe27a Mon Sep 17 00:00:00 2001 From: Andrew Or Date: Thu, 30 Oct 2014 16:36:31 -0700 Subject: [PATCH] Test --- .../scala/org/apache/spark/mapred/SparkHadoopMapRedUtil.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/main/scala/org/apache/spark/mapred/SparkHadoopMapRedUtil.scala b/core/src/main/scala/org/apache/spark/mapred/SparkHadoopMapRedUtil.scala index fe2bc65f89ab4..75f72cf84fca2 100644 --- a/core/src/main/scala/org/apache/spark/mapred/SparkHadoopMapRedUtil.scala +++ b/core/src/main/scala/org/apache/spark/mapred/SparkHadoopMapRedUtil.scala @@ -30,6 +30,7 @@ trait SparkHadoopMapRedUtil { } def newTaskAttemptContext(conf: JobConf, attemptId: TaskAttemptID): TaskAttemptContext = { + println(attemptId.toString) val klass = firstAvailableClass("org.apache.hadoop.mapred.TaskAttemptContextImpl", "org.apache.hadoop.mapred.TaskAttemptContext") val ctor = klass.getDeclaredConstructor(classOf[JobConf], classOf[TaskAttemptID])