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 {
60
60
Seq (
61
61
excludePackage(" org.apache.spark.api.java" ),
62
62
excludePackage(" org.apache.spark.streaming.api.java" ),
63
+ excludePackage(" org.apache.spark.streaming.scheduler" ),
63
64
excludePackage(" org.apache.spark.mllib" )
64
65
) ++
65
66
excludeSparkClass(" rdd.ClassTags" ) ++
@@ -70,7 +71,12 @@ object MimaBuild {
70
71
excludeSparkClass(" mllib.regression.LassoWithSGD" ) ++
71
72
excludeSparkClass(" mllib.regression.LinearRegressionWithSGD" ) ++
72
73
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" )
74
80
case _ => Seq ()
75
81
}
76
82
Original file line number Diff line number Diff line change @@ -79,7 +79,7 @@ private[ui] class StreamingPage(parent: StreamingTab)
79
79
val headerRow = Seq (
80
80
" Receiver" ,
81
81
" Location" ,
82
- " Records in last batch\n [" + formatDate(Calendar .getInstance().getTime())+ " ]" ,
82
+ " Records in last batch\n [" + formatDate(Calendar .getInstance().getTime()) + " ]" ,
83
83
" Minimum rate\n [records/sec]" ,
84
84
" 25th percentile rate\n [records/sec]" ,
85
85
" Median rate\n [records/sec]" ,
You can’t perform that action at this time.
0 commit comments