@@ -20,15 +20,15 @@ package org.apache.spark.streaming
20
20
import java .io .{File , NotSerializableException }
21
21
import java .util .concurrent .atomic .AtomicInteger
22
22
23
- import scala .collection .mutable .Queue
24
23
import scala .collection .mutable .ArrayBuffer
24
+ import scala .collection .mutable .Queue
25
25
26
26
import org .apache .commons .io .FileUtils
27
27
import org .scalatest .concurrent .Eventually ._
28
28
import org .scalatest .concurrent .Timeouts
29
29
import org .scalatest .exceptions .TestFailedDueToTimeoutException
30
30
import org .scalatest .time .SpanSugar ._
31
- import org .scalatest .{PrivateMethodTester , Assertions , BeforeAndAfter }
31
+ import org .scalatest .{Assertions , BeforeAndAfter , PrivateMethodTester }
32
32
33
33
import org .apache .spark .metrics .MetricsSystem
34
34
import org .apache .spark .metrics .source .Source
@@ -839,7 +839,6 @@ package object testPackage extends Assertions {
839
839
* Helper methods for testing StreamingContextSuite
840
840
* This includes methods to access private methods and fields in StreamingContext and MetricsSystem
841
841
*/
842
-
843
842
private object StreamingContextSuite extends PrivateMethodTester {
844
843
private val _sources = PrivateMethod [ArrayBuffer [Source ]](' sources )
845
844
private def getSources (metricsSystem : MetricsSystem ): ArrayBuffer [Source ] = {
0 commit comments