We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ce0fa73 commit ec6ec58Copy full SHA for ec6ec58
streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobScheduler.scala
@@ -17,9 +17,11 @@
17
18
package org.apache.spark.streaming.scheduler
19
20
-import scala.util.{Failure, Success}
21
-import scala.collection.JavaConversions._
22
import java.util.concurrent.{TimeUnit, ConcurrentHashMap, Executors}
+
+import scala.collection.JavaConversions._
23
+import scala.util.{Failure, Success}
24
25
import org.apache.spark.Logging
26
import org.apache.spark.rdd.PairRDDFunctions
27
import org.apache.spark.streaming._
0 commit comments