File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
streaming/src/test/scala/org/apache/spark/streaming Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -184,8 +184,8 @@ class ReceiverSuite extends TestSuiteBase with Timeouts with Serializable {
184
184
assert(blockGeneratorListener.arrayBuffers.size > 0 , " No blocks received" )
185
185
assert(recordedData.toSet === generatedData.toSet, " Received data not same" )
186
186
187
- // recordedData size should be close to the expected rate
188
- // use an error margin proportional to the value, so that rate changes don't cause a brittle test
187
+ // recordedData size should be close to the expected rate; use an error margin proportional to
188
+ // the value, so that rate changes don't cause a brittle test
189
189
val minExpectedMessages = expectedMessages - 0.01 * expectedMessages
190
190
val maxExpectedMessages = expectedMessages + 0.01 * expectedMessages
191
191
val numMessages = recordedData.size
@@ -205,7 +205,8 @@ class ReceiverSuite extends TestSuiteBase with Timeouts with Serializable {
205
205
val averageBlockSize = validBlocks.map(block => block.size).sum / validBlocks.size
206
206
207
207
assert(
208
- averageBlockSize >= minExpectedMessagesPerBlock && averageBlockSize <= maxExpectedMessagesPerBlock,
208
+ averageBlockSize >= minExpectedMessagesPerBlock &&
209
+ averageBlockSize <= maxExpectedMessagesPerBlock,
209
210
s " # records in received blocks = [ $receivedBlockSizes], not between " +
210
211
s " $minExpectedMessagesPerBlock and $maxExpectedMessagesPerBlock, on average "
211
212
)
You can’t perform that action at this time.
0 commit comments