diff options
| author | Shivaram Venkataraman <shivaram@eecs.berkeley.edu> | 2013-06-13 14:46:25 -0700 |
|---|---|---|
| committer | Shivaram Venkataraman <shivaram@eecs.berkeley.edu> | 2013-06-13 14:46:25 -0700 |
| commit | 1d9f0df0652f455145d2dfed43a9407df6de6c43 (patch) | |
| tree | a7c5c67de82617c632fa2c0d10a2916df49b0044 /core/src/test/scala | |
| parent | 5da4287b1dbfb8cfcec9c915926d8a8755bd52b2 (diff) | |
| download | spark-1d9f0df0652f455145d2dfed43a9407df6de6c43.tar.gz spark-1d9f0df0652f455145d2dfed43a9407df6de6c43.tar.bz2 spark-1d9f0df0652f455145d2dfed43a9407df6de6c43.zip | |
Fix some comments and style
Diffstat (limited to 'core/src/test/scala')
| -rw-r--r-- | core/src/test/scala/spark/ShuffleSuite.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/core/src/test/scala/spark/ShuffleSuite.scala b/core/src/test/scala/spark/ShuffleSuite.scala index 33b02fff80..1916885a73 100644 --- a/core/src/test/scala/spark/ShuffleSuite.scala +++ b/core/src/test/scala/spark/ShuffleSuite.scala @@ -376,8 +376,7 @@ class ShuffleSuite extends FunSuite with ShouldMatchers with LocalSparkContext { val a = sc.parallelize(1 to 4, NUM_BLOCKS) val b = a.map(x => (x, x*2)) - // NOTE: The default Java serializer doesn't create zero-sized blocks. - // So, use Kryo + // NOTE: The default Java serializer should create zero-sized blocks val c = new ShuffledRDD(b, new HashPartitioner(10)) val shuffleId = c.dependencies.head.asInstanceOf[ShuffleDependency[Int, Int]].shuffleId |