Skip to content

Commit b0a18b1

Browse files
committed
Fixed import order.
1 parent 20aa7c6 commit b0a18b1

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

streaming/src/main/scala/org/apache/spark/streaming/rdd/WriteAheadLogBackedBlockRDD.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@ package org.apache.spark.streaming.rdd
1919
import scala.reflect.ClassTag
2020

2121
import org.apache.hadoop.conf.Configuration
22+
2223
import org.apache.spark._
2324
import org.apache.spark.rdd.BlockRDD
2425
import org.apache.spark.storage.{BlockId, StorageLevel}

streaming/src/test/scala/org/apache/spark/streaming/rdd/WriteAheadLogBackedBlockRDDSuite.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,10 +22,11 @@ import scala.util.Random
2222

2323
import com.google.common.io.Files
2424
import org.apache.hadoop.conf.Configuration
25+
import org.scalatest.{BeforeAndAfterAll, FunSuite}
26+
2527
import org.apache.spark.{SparkConf, SparkContext}
2628
import org.apache.spark.storage.{BlockId, BlockManager, StorageLevel, StreamBlockId}
2729
import org.apache.spark.streaming.util.{WriteAheadLogFileSegment, WriteAheadLogWriter}
28-
import org.scalatest.{BeforeAndAfterAll, FunSuite}
2930

3031
class WriteAheadLogBackedBlockRDDSuite extends FunSuite with BeforeAndAfterAll {
3132
val conf = new SparkConf()

0 commit comments

Comments
 (0)