diff options
Diffstat (limited to 'bagel')
| -rw-r--r-- | bagel/src/main/scala/spark/bagel/Bagel.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/bagel/src/main/scala/spark/bagel/Bagel.scala b/bagel/src/main/scala/spark/bagel/Bagel.scala index 08ff1d8a01..92d4132e68 100644 --- a/bagel/src/main/scala/spark/bagel/Bagel.scala +++ b/bagel/src/main/scala/spark/bagel/Bagel.scala @@ -14,7 +14,7 @@ object Bagel extends Logging { combiner: Combiner[M, C] = new DefaultCombiner[M], aggregator: Aggregator[V, A] = new NullAggregator[V], superstep: Int = 0, - numSplits: Int = sc.numCores + numSplits: Int = sc.defaultParallelism )( compute: (V, Option[C], A, Int) => (V, Iterable[M]) ): RDD[V] = { |