diff options
| author | Dmitriy Lyubimov <dlyubimov@apache.org> | 2013-07-30 16:13:41 -0700 |
|---|---|---|
| committer | Dmitriy Lyubimov <dlyubimov@apache.org> | 2013-07-30 16:13:41 -0700 |
| commit | 43394b9a6d37bb3e4b5ebce9db2160e2a35bb279 (patch) | |
| tree | 34335bd998ac19f1bbe1a895de8f415d2ca894db /core | |
| parent | 13a9d666457533bd0c3991c1d3bc30474e08e580 (diff) | |
| download | spark-43394b9a6d37bb3e4b5ebce9db2160e2a35bb279.tar.gz spark-43394b9a6d37bb3e4b5ebce9db2160e2a35bb279.tar.bz2 spark-43394b9a6d37bb3e4b5ebce9db2160e2a35bb279.zip | |
fixing formatting
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/scheduler/TaskResult.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/scheduler/TaskResult.scala b/core/src/main/scala/spark/scheduler/TaskResult.scala index 55d1105ccf..7016ece40e 100644 --- a/core/src/main/scala/spark/scheduler/TaskResult.scala +++ b/core/src/main/scala/spark/scheduler/TaskResult.scala @@ -36,7 +36,7 @@ class TaskResult[T](var value: T, var accumUpdates: Map[Long, Any], var metrics: val objectSer = SparkEnv.get.serializer.newInstance() val bb = objectSer.serialize(value) - out.writeInt( bb.remaining()) + out.writeInt(bb.remaining()) if (bb.hasArray) { out.write(bb.array(), bb.arrayOffset() + bb.position(), bb.remaining()) } else { |