From 38f3ca8a4fb7845aebd855ccaa73339fba5ca091 Mon Sep 17 00:00:00 2001 From: David McGuire Date: Fri, 17 Apr 2015 10:05:30 -0700 Subject: [PATCH] Ratchet down the error rate to +/- 5%; tests fail --- .../scala/org/apache/spark/streaming/ReceiverSuite.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/streaming/src/test/scala/org/apache/spark/streaming/ReceiverSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/ReceiverSuite.scala index 239f83d1c8efc..f2dfd834d456c 100644 --- a/streaming/src/test/scala/org/apache/spark/streaming/ReceiverSuite.scala +++ b/streaming/src/test/scala/org/apache/spark/streaming/ReceiverSuite.scala @@ -187,16 +187,16 @@ class ReceiverSuite extends TestSuiteBase with Timeouts with Serializable { // recordedData size should be close to the expected rate // use an error margin proportional to the value, so that rate changes don't cause a brittle test - val minExpectedMessages = expectedMessages - 0.3 * expectedMessages - val maxExpectedMessages = expectedMessages + 0.1 * expectedMessages + val minExpectedMessages = expectedMessages - 0.05 * expectedMessages + val maxExpectedMessages = expectedMessages + 0.05 * expectedMessages val numMessages = recordedData.size assert( numMessages >= minExpectedMessages && numMessages <= maxExpectedMessages, s"#records received = $numMessages, not between $minExpectedMessages and $maxExpectedMessages" ) - val minExpectedMessagesPerBlock = expectedMessagesPerBlock - 0.3 * expectedMessagesPerBlock - val maxExpectedMessagesPerBlock = expectedMessagesPerBlock + 0.1 * expectedMessagesPerBlock + val minExpectedMessagesPerBlock = expectedMessagesPerBlock - 0.05 * expectedMessagesPerBlock + val maxExpectedMessagesPerBlock = expectedMessagesPerBlock + 0.05 * expectedMessagesPerBlock val receivedBlockSizes = recordedBlocks.map { _.size }.mkString(",") assert( // the first and last block may be incomplete, so we slice them out