@@ -312,14 +312,14 @@ class ExchangeCoordinatorSuite extends SparkFunSuite with BeforeAndAfterAll {
312
312
minNumPostShufflePartitions match {
313
313
case Some (numPartitions) =>
314
314
queryStageInputs.foreach { q =>
315
- assert(q.partitionStartIndices.isDefined)
316
- assert(q.outputPartitioning.numPartitions === 5 )
315
+ assert(q.partitionStartIndices.isDefined)
316
+ assert(q.outputPartitioning.numPartitions === 5 )
317
317
}
318
318
319
319
case None =>
320
320
queryStageInputs.foreach { q =>
321
- assert(q.partitionStartIndices.isDefined)
322
- assert(q.outputPartitioning.numPartitions === 3 )
321
+ assert(q.partitionStartIndices.isDefined)
322
+ assert(q.outputPartitioning.numPartitions === 3 )
323
323
}
324
324
}
325
325
}
@@ -359,14 +359,14 @@ class ExchangeCoordinatorSuite extends SparkFunSuite with BeforeAndAfterAll {
359
359
minNumPostShufflePartitions match {
360
360
case Some (numPartitions) =>
361
361
queryStageInputs.foreach { q =>
362
- assert(q.partitionStartIndices.isDefined)
363
- assert(q.outputPartitioning.numPartitions === 5 )
362
+ assert(q.partitionStartIndices.isDefined)
363
+ assert(q.outputPartitioning.numPartitions === 5 )
364
364
}
365
365
366
366
case None =>
367
367
queryStageInputs.foreach { q =>
368
- assert(q.partitionStartIndices.isDefined)
369
- assert(q.outputPartitioning.numPartitions === 2 )
368
+ assert(q.partitionStartIndices.isDefined)
369
+ assert(q.outputPartitioning.numPartitions === 2 )
370
370
}
371
371
}
372
372
}
@@ -411,14 +411,14 @@ class ExchangeCoordinatorSuite extends SparkFunSuite with BeforeAndAfterAll {
411
411
minNumPostShufflePartitions match {
412
412
case Some (numPartitions) =>
413
413
queryStageInputs.foreach { q =>
414
- assert(q.partitionStartIndices.isDefined)
415
- assert(q.outputPartitioning.numPartitions === 5 )
414
+ assert(q.partitionStartIndices.isDefined)
415
+ assert(q.outputPartitioning.numPartitions === 5 )
416
416
}
417
417
418
418
case None =>
419
419
queryStageInputs.foreach { q =>
420
- assert(q.partitionStartIndices.isDefined)
421
- assert(q.outputPartitioning.numPartitions === 2 )
420
+ assert(q.partitionStartIndices.isDefined)
421
+ assert(q.outputPartitioning.numPartitions === 2 )
422
422
}
423
423
}
424
424
}
@@ -463,14 +463,14 @@ class ExchangeCoordinatorSuite extends SparkFunSuite with BeforeAndAfterAll {
463
463
minNumPostShufflePartitions match {
464
464
case Some (numPartitions) =>
465
465
queryStageInputs.foreach { q =>
466
- assert(q.partitionStartIndices.isDefined)
467
- assert(q.outputPartitioning.numPartitions === 5 )
466
+ assert(q.partitionStartIndices.isDefined)
467
+ assert(q.outputPartitioning.numPartitions === 5 )
468
468
}
469
469
470
470
case None =>
471
471
queryStageInputs.foreach { q =>
472
- assert(q.partitionStartIndices.isDefined)
473
- assert(q.outputPartitioning.numPartitions === 3 )
472
+ assert(q.partitionStartIndices.isDefined)
473
+ assert(q.outputPartitioning.numPartitions === 3 )
474
474
}
475
475
}
476
476
}
0 commit comments