This commit is contained in:
Patrick Wendell 2012-09-28 16:05:50 -07:00
Родитель bc909c2903
Коммит 9fc78f8f29
1 изменённых файлов: 9 добавлений и 9 удалений

Просмотреть файл

@ -145,15 +145,15 @@ abstract class RDD[T: ClassManifest](@transient sc: SparkContext) extends Serial
for (el <- trace) {
if (!finished) {
if (el.getClassName().contains("spark") && !el.getClassName().startsWith("spark.examples")) {
lastSparkMethod = el.getMethodName()
}
else {
firstUserMethod = el.getMethodName()
firstUserLine = el.getLineNumber()
firstUserFile = el.getFileName()
finished = true
}
if (el.getClassName().contains("spark") && !el.getClassName().startsWith("spark.examples")) {
lastSparkMethod = el.getMethodName()
}
else {
firstUserMethod = el.getMethodName()
firstUserLine = el.getLineNumber()
firstUserFile = el.getFileName()
finished = true
}
}
}
"%s at: %s (%s:%s)".format(lastSparkMethod, firstUserMethod, firstUserFile, firstUserLine)