Added binary check exclusions

markhamstra · Apr 11, 2014 · 2fc09c8 · 2fc09c8
1 parent f8e1053
commit 2fc09c8
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/project/MimaBuild.scala b/project/MimaBuild.scala
@@ -60,6 +60,7 @@ object MimaBuild {
           Seq(
             excludePackage("org.apache.spark.api.java"),
             excludePackage("org.apache.spark.streaming.api.java"),
+            excludePackage("org.apache.spark.streaming.scheduler"),
             excludePackage("org.apache.spark.mllib")
           ) ++
           excludeSparkClass("rdd.ClassTags") ++
@@ -70,7 +71,12 @@ object MimaBuild {
           excludeSparkClass("mllib.regression.LassoWithSGD") ++
           excludeSparkClass("mllib.regression.LinearRegressionWithSGD") ++
           excludeSparkClass("streaming.dstream.NetworkReceiver") ++
-          excludeSparkClass("streaming.dstream.NetworkReceiver#NetworkReceiverActor")
+          excludeSparkClass("streaming.dstream.NetworkReceiver#NetworkReceiverActor") ++
+          excludeSparkClass("streaming.dstream.NetworkReceiver#BlockGenerator") ++
+          excludeSparkClass("streaming.dstream.NetworkReceiver#BlockGenerator#Block") ++
+          excludeSparkClass("streaming.dstream.ReportError") ++
+          excludeSparkClass("org.apache.spark.streaming.dstream.ReportBlock") ++
+          excludeSparkClass("org.apache.spark.streaming.dstream.DStream")
         case _ => Seq()
       }
 

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
@@ -79,7 +79,7 @@ private[ui] class StreamingPage(parent: StreamingTab)
       val headerRow = Seq(
         "Receiver",
         "Location",
-        "Records in last batch\n[" + formatDate(Calendar.getInstance().getTime())+ "]",
+        "Records in last batch\n[" + formatDate(Calendar.getInstance().getTime()) + "]",
         "Minimum rate\n[records/sec]",
         "25th percentile rate\n[records/sec]",
         "Median rate\n[records/sec]",