From ddf741a35feaa7bccf7c99289171e4120278e1aa Mon Sep 17 00:00:00 2001 From: zsxwing Date: Wed, 22 Apr 2015 13:01:43 +0800 Subject: [PATCH] Fix the unit test --- .../org/apache/spark/streaming/ui/StreamingPage.scala | 2 +- .../org/apache/spark/streaming/UISeleniumSuite.scala | 10 ++++------ 2 files changed, 5 insertions(+), 7 deletions(-) diff --git a/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingPage.scala b/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingPage.scala index 843d2102bbbe5..2baccafa00993 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingPage.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingPage.scala @@ -318,7 +318,7 @@ private[ui] class StreamingPage(parent: StreamingTab) maxY: Long): Seq[Node] = { val content = listener.receivedRecordsDistributions.map { case (receiverId, distribution) => generateInputReceiverRow(jsCollector, receiverId, distribution, minX, maxX, minY, maxY) - }.reduce(_ ++ _) + }.foldLeft[Seq[Node]](Nil)(_ ++ _) diff --git a/streaming/src/test/scala/org/apache/spark/streaming/UISeleniumSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/UISeleniumSuite.scala index 205ddf6dbe9b0..a2f4f3fe19897 100644 --- a/streaming/src/test/scala/org/apache/spark/streaming/UISeleniumSuite.scala +++ b/streaming/src/test/scala/org/apache/spark/streaming/UISeleniumSuite.scala @@ -72,9 +72,8 @@ class UISeleniumSuite eventually(timeout(10 seconds), interval(50 milliseconds)) { // check whether streaming page exists go to (sparkUI.appUIAddress.stripSuffix("/") + "/streaming") - val statisticText = findAll(cssSelector("li strong")).map(_.text).toSeq - statisticText should contain("Network receivers:") - statisticText should contain("Batch interval:") + val h3Text = findAll(cssSelector("h3")).map(_.text).toSeq + h3Text should contain("Streaming Statistics") val h4Text = findAll(cssSelector("h4")).map(_.text).toSeq h4Text should contain("Active Batches (0)") @@ -97,9 +96,8 @@ class UISeleniumSuite eventually(timeout(10 seconds), interval(50 milliseconds)) { go to (sparkUI.appUIAddress.stripSuffix("/") + "/streaming") - val statisticText = findAll(cssSelector("li strong")).map(_.text).toSeq - statisticText should not contain ("Network receivers:") - statisticText should not contain ("Batch interval:") + val h3Text = findAll(cssSelector("h3")).map(_.text).toSeq + h3Text should not contain("Streaming Statistics") } } }