Skip to content
Snippets Groups Projects
Commit d6fd9b37 authored by Yin Huai's avatar Yin Huai
Browse files

[SPARK-12692][BUILD][HOT-FIX] Fix the scala style of KinesisBackedBlockRDDSuite.scala.

https://github.com/apache/spark/pull/10736 was merged yesterday and caused the master start to fail because of the style issue.

Author: Yin Huai <yhuai@databricks.com>

Closes #10742 from yhuai/fixStyle.
parent 3d81d63f
No related branches found
No related tags found
No related merge requests found
...@@ -158,9 +158,9 @@ abstract class KinesisBackedBlockRDDTests(aggregateTestData: Boolean) ...@@ -158,9 +158,9 @@ abstract class KinesisBackedBlockRDDTests(aggregateTestData: Boolean)
testBlockRemove: Boolean = false testBlockRemove: Boolean = false
): Unit = { ): Unit = {
require(shardIds.size > 1, "Need at least 2 shards to test") require(shardIds.size > 1, "Need at least 2 shards to test")
require(numPartitionsInBM <= shardIds.size , require(numPartitionsInBM <= shardIds.size,
"Number of partitions in BlockManager cannot be more than the Kinesis test shards available") "Number of partitions in BlockManager cannot be more than the Kinesis test shards available")
require(numPartitionsInKinesis <= shardIds.size , require(numPartitionsInKinesis <= shardIds.size,
"Number of partitions in Kinesis cannot be more than the Kinesis test shards available") "Number of partitions in Kinesis cannot be more than the Kinesis test shards available")
require(numPartitionsInBM <= numPartitions, require(numPartitionsInBM <= numPartitions,
"Number of partitions in BlockManager cannot be more than that in RDD") "Number of partitions in BlockManager cannot be more than that in RDD")
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment