Fix a compile error

2011-06-27 18:07:16 -07:00 · 2011-06-27 18:07:16 -07:00 · 2f652f1656
parent ae63972a89
commit 2f652f1656
1 changed files with 1 additions and 1 deletions
--- a/core/src/main/scala/spark/RDD.scala
+++ b/core/src/main/scala/spark/RDD.scala
@ -463,7 +463,7 @@ class SequencePairRDDExtras[K <% Writable: ClassManifest, V <% Writable : ClassM
            buf += v
          buf
        }
-        val res = self.context.runJob(self, process, Array(index))
+        val res = self.context.runJob(self, process _, Array(index))
        res(0)
      case None =>
        throw new UnsupportedOperationException("lookup() called on an RDD without a partitioner")