diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2014-04-10 02:10:40 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-04-10 02:10:40 -0700 |
| commit | e6d4a74d2d92345985c1603f9b526a6347adb7cf (patch) | |
| tree | e22221efdcf5eb5eac305ef12d2604d0198d697c /graphx | |
| parent | e55cc4bae52a3de728939244780abc662713b768 (diff) | |
| download | spark-e6d4a74d2d92345985c1603f9b526a6347adb7cf.tar.gz spark-e6d4a74d2d92345985c1603f9b526a6347adb7cf.tar.bz2 spark-e6d4a74d2d92345985c1603f9b526a6347adb7cf.zip | |
Revert "SPARK-729: Closures not always serialized at capture time"
This reverts commit 8ca3b2bc90a63b23a03f339e390174cd7a672b40.
Diffstat (limited to 'graphx')
| -rw-r--r-- | graphx/src/test/scala/org/apache/spark/graphx/GraphSuite.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/graphx/src/test/scala/org/apache/spark/graphx/GraphSuite.scala b/graphx/src/test/scala/org/apache/spark/graphx/GraphSuite.scala index c65e36636f..28d34dd9a1 100644 --- a/graphx/src/test/scala/org/apache/spark/graphx/GraphSuite.scala +++ b/graphx/src/test/scala/org/apache/spark/graphx/GraphSuite.scala @@ -62,7 +62,7 @@ class GraphSuite extends FunSuite with LocalSparkContext { assert( graph.edges.count() === rawEdges.size ) // Vertices not explicitly provided but referenced by edges should be created automatically assert( graph.vertices.count() === 100) - graph.triplets.collect.map { et => + graph.triplets.map { et => assert((et.srcId < 10 && et.srcAttr) || (et.srcId >= 10 && !et.srcAttr)) assert((et.dstId < 10 && et.dstAttr) || (et.dstId >= 10 && !et.dstAttr)) } |