fixed test

Author: tdas

core/src/main/scala/org/apache/spark/ui/UIUtils.scala

@@ -398,8 +398,9 @@ private[spark] object UIUtils extends Logging {
   }
 
   /**
-   * Convert a description string to HTML. It will try to parse the string as HTML and sanitize
-   * any links. If that fails, then whole string will treated as a simple text.
+   * Returns HTML rendering of a job or stage description. It will try to parse the string as HTML
+   * and make sure that it only contains anchors with relative links. Otherwise, the whole string
+   * will rendered as a simple escaped text.
    */
   def makeDescription(desc: String, basePathUri: String): NodeSeq = {
     import scala.language.postfixOps
@@ -426,7 +427,7 @@ private[spark] object UIUtils extends Logging {
         xml \\ "a" flatMap { _.attributes } filter { _.key == "href" } map { _.value.toString }
       if (allLinks.exists { ! _.startsWith ("/") }) {
         throw new IllegalArgumentException(
-          "Links in job descriptions must be relative:\n" + allLinks.mkString("\n\t"))
+          "Links in job descriptions must be root-relative:\n" + allLinks.mkString("\n\t"))
       }
 
       // Prepend the relative links with basePathUri

streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala

@@ -30,7 +30,7 @@ import org.apache.spark.rdd.RDD
 import org.apache.spark.rpc._
 import org.apache.spark.streaming.{StreamingContext, Time}
 import org.apache.spark.streaming.receiver._
-import org.apache.spark.util.{ThreadUtils, SerializableConfiguration}
+import org.apache.spark.util.{Utils, ThreadUtils, SerializableConfiguration}
 
 
 /** Enumeration to identify current state of a Receiver */
@@ -555,7 +555,7 @@ class ReceiverTracker(ssc: StreamingContext, skipReceiverLaunch: Boolean = false
         }
       receiverRDD.setName(s"Receiver $receiverId")
       ssc.sparkContext.setJobDescription(s"Streaming job running receiver $receiverId")
-      ssc.sparkContext.setCallSite(ssc.getStartSite())
+      ssc.sparkContext.setCallSite(Option(ssc.getStartSite()).getOrElse(Utils.getCallSite()))
 
       val future = ssc.sparkContext.submitJob[Receiver[_], Unit, Unit](
         receiverRDD, startReceiverFunc, Seq(0), (_, _) => Unit, ())