aboutsummaryrefslogtreecommitdiff
path: root/core/src/main
diff options
context:
space:
mode:
authorPatrick Wendell <pwendell@gmail.com>2012-09-28 16:05:50 -0700
committerPatrick Wendell <pwendell@gmail.com>2012-09-28 16:05:50 -0700
commit9fc78f8f2907828c448fd53155ec01203212321d (patch)
treee67c348af03412c88fff5fbd1c170c8bf5740d37 /core/src/main
parentbc909c2903f80452b62091c9a32fd7587a41b218 (diff)
downloadspark-9fc78f8f2907828c448fd53155ec01203212321d.tar.gz
spark-9fc78f8f2907828c448fd53155ec01203212321d.tar.bz2
spark-9fc78f8f2907828c448fd53155ec01203212321d.zip
Fixing some whitespace issues
Diffstat (limited to 'core/src/main')
-rw-r--r--core/src/main/scala/spark/RDD.scala18
1 files changed, 9 insertions, 9 deletions
diff --git a/core/src/main/scala/spark/RDD.scala b/core/src/main/scala/spark/RDD.scala
index 8590d487cc..cce1acc2ca 100644
--- a/core/src/main/scala/spark/RDD.scala
+++ b/core/src/main/scala/spark/RDD.scala
@@ -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)