@@ -20,15 +20,15 @@ package org.apache.spark.streaming
2020import java .io .{File , NotSerializableException }
2121import java .util .concurrent .atomic .AtomicInteger
2222
23- import scala .collection .mutable .Queue
2423import scala .collection .mutable .ArrayBuffer
24+ import scala .collection .mutable .Queue
2525
2626import org .apache .commons .io .FileUtils
2727import org .scalatest .concurrent .Eventually ._
2828import org .scalatest .concurrent .Timeouts
2929import org .scalatest .exceptions .TestFailedDueToTimeoutException
3030import org .scalatest .time .SpanSugar ._
31- import org .scalatest .{PrivateMethodTester , Assertions , BeforeAndAfter }
31+ import org .scalatest .{Assertions , BeforeAndAfter , PrivateMethodTester }
3232
3333import org .apache .spark .metrics .MetricsSystem
3434import org .apache .spark .metrics .source .Source
@@ -839,7 +839,6 @@ package object testPackage extends Assertions {
839839 * Helper methods for testing StreamingContextSuite
840840 * This includes methods to access private methods and fields in StreamingContext and MetricsSystem
841841 */
842-
843842private object StreamingContextSuite extends PrivateMethodTester {
844843 private val _sources = PrivateMethod [ArrayBuffer [Source ]](' sources )
845844 private def getSources (metricsSystem : MetricsSystem ): ArrayBuffer [Source ] = {
0 commit comments