File tree Expand file tree Collapse file tree 2 files changed +8
-2
lines changed
streaming/src/main/scala/org/apache/spark/streaming/ui Expand file tree Collapse file tree 2 files changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -60,6 +60,7 @@ object MimaBuild {
6060 Seq (
6161 excludePackage(" org.apache.spark.api.java" ),
6262 excludePackage(" org.apache.spark.streaming.api.java" ),
63+ excludePackage(" org.apache.spark.streaming.scheduler" ),
6364 excludePackage(" org.apache.spark.mllib" )
6465 ) ++
6566 excludeSparkClass(" rdd.ClassTags" ) ++
@@ -70,7 +71,12 @@ object MimaBuild {
7071 excludeSparkClass(" mllib.regression.LassoWithSGD" ) ++
7172 excludeSparkClass(" mllib.regression.LinearRegressionWithSGD" ) ++
7273 excludeSparkClass(" streaming.dstream.NetworkReceiver" ) ++
73- excludeSparkClass(" streaming.dstream.NetworkReceiver#NetworkReceiverActor" )
74+ excludeSparkClass(" streaming.dstream.NetworkReceiver#NetworkReceiverActor" ) ++
75+ excludeSparkClass(" streaming.dstream.NetworkReceiver#BlockGenerator" ) ++
76+ excludeSparkClass(" streaming.dstream.NetworkReceiver#BlockGenerator#Block" ) ++
77+ excludeSparkClass(" streaming.dstream.ReportError" ) ++
78+ excludeSparkClass(" org.apache.spark.streaming.dstream.ReportBlock" ) ++
79+ excludeSparkClass(" org.apache.spark.streaming.dstream.DStream" )
7480 case _ => Seq ()
7581 }
7682
Original file line number Diff line number Diff line change @@ -79,7 +79,7 @@ private[ui] class StreamingPage(parent: StreamingTab)
7979 val headerRow = Seq (
8080 " Receiver" ,
8181 " Location" ,
82- " Records in last batch\n [" + formatDate(Calendar .getInstance().getTime())+ " ]" ,
82+ " Records in last batch\n [" + formatDate(Calendar .getInstance().getTime()) + " ]" ,
8383 " Minimum rate\n [records/sec]" ,
8484 " 25th percentile rate\n [records/sec]" ,
8585 " Median rate\n [records/sec]" ,
You can’t perform that action at this time.
0 commit comments