Fixed minor bugs.

Author: tdas

core/src/main/scala/org/apache/spark/util/Utils.scala

@@ -906,7 +906,7 @@ private[spark] object Utils extends Logging {
     for (el <- trace) {
       if (insideSpark) {
         if (!classFilterFunc(el.getClassName)) {
-            lastSparkMethod = if (el.getMethodName == "<init>") {
+          lastSparkMethod = if (el.getMethodName == "<init>") {
             // Spark method is a constructor; get its class name
             el.getClassName.substring(el.getClassName.lastIndexOf('.') + 1)
           } else {

streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala

@@ -253,16 +253,6 @@ abstract class DStream[T: ClassTag] (
     dependencies.foreach(_.setGraph(graph))
   }
 
-  /* Set the custom RDD creation site as this thread's local property. */
-  private def setRDDCreationSite(creationSite: CallSite): Unit = {
-
-  }
-
-  /* Get the custom RDD creation site set as this thread's local property. */
-  private def getRDDCreationSite(): CallSite = {
-    ssc.sparkContext.getCallSite()
-  }
-
   private[streaming] def remember(duration: Duration) {
     if (duration != null && duration > rememberDuration) {
       rememberDuration = duration