aboutsummaryrefslogtreecommitdiff
path: root/streaming
diff options
context:
space:
mode:
authorJacek Laskowski <jacek@japila.pl>2016-11-02 09:21:26 +0000
committerSean Owen <sowen@cloudera.com>2016-11-02 09:21:26 +0000
commit70a5db7bbd192a4bc68bcfdc475ab221adf2fcdd (patch)
treed2e51c677e7a0fc1af79d892e111550c4fc9536f /streaming
parent98ede49496d0d7b4724085083d4f24436b92a7bf (diff)
downloadspark-70a5db7bbd192a4bc68bcfdc475ab221adf2fcdd.tar.gz
spark-70a5db7bbd192a4bc68bcfdc475ab221adf2fcdd.tar.bz2
spark-70a5db7bbd192a4bc68bcfdc475ab221adf2fcdd.zip
[SPARK-18204][WEBUI] Remove SparkUI.appUIAddress
## What changes were proposed in this pull request? Removing `appUIAddress` attribute since it is no longer in use. ## How was this patch tested? Local build Author: Jacek Laskowski <jacek@japila.pl> Closes #15603 from jaceklaskowski/sparkui-fixes.
Diffstat (limited to 'streaming')
-rw-r--r--streaming/src/test/scala/org/apache/spark/streaming/UISeleniumSuite.scala12
1 files changed, 6 insertions, 6 deletions
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 454c3dffa3..e7cec999c2 100644
--- a/streaming/src/test/scala/org/apache/spark/streaming/UISeleniumSuite.scala
+++ b/streaming/src/test/scala/org/apache/spark/streaming/UISeleniumSuite.scala
@@ -92,13 +92,13 @@ class UISeleniumSuite
val sparkUI = ssc.sparkContext.ui.get
eventually(timeout(10 seconds), interval(50 milliseconds)) {
- go to (sparkUI.appUIAddress.stripSuffix("/"))
+ go to (sparkUI.webUrl.stripSuffix("/"))
find(cssSelector( """ul li a[href*="streaming"]""")) should not be (None)
}
eventually(timeout(10 seconds), interval(50 milliseconds)) {
// check whether streaming page exists
- go to (sparkUI.appUIAddress.stripSuffix("/") + "/streaming")
+ go to (sparkUI.webUrl.stripSuffix("/") + "/streaming")
val h3Text = findAll(cssSelector("h3")).map(_.text).toSeq
h3Text should contain("Streaming Statistics")
@@ -180,23 +180,23 @@ class UISeleniumSuite
jobDetails should contain("Completed Stages:")
// Check a batch page without id
- go to (sparkUI.appUIAddress.stripSuffix("/") + "/streaming/batch/")
+ go to (sparkUI.webUrl.stripSuffix("/") + "/streaming/batch/")
webDriver.getPageSource should include ("Missing id parameter")
// Check a non-exist batch
- go to (sparkUI.appUIAddress.stripSuffix("/") + "/streaming/batch/?id=12345")
+ go to (sparkUI.webUrl.stripSuffix("/") + "/streaming/batch/?id=12345")
webDriver.getPageSource should include ("does not exist")
}
ssc.stop(false)
eventually(timeout(10 seconds), interval(50 milliseconds)) {
- go to (sparkUI.appUIAddress.stripSuffix("/"))
+ go to (sparkUI.webUrl.stripSuffix("/"))
find(cssSelector( """ul li a[href*="streaming"]""")) should be(None)
}
eventually(timeout(10 seconds), interval(50 milliseconds)) {
- go to (sparkUI.appUIAddress.stripSuffix("/") + "/streaming")
+ go to (sparkUI.webUrl.stripSuffix("/") + "/streaming")
val h3Text = findAll(cssSelector("h3")).map(_.text).toSeq
h3Text should not contain("Streaming Statistics")
}