File tree Expand file tree Collapse file tree 3 files changed +9
-10
lines changed
src/test/scala/org/apache/spark/streaming/flume/sink Expand file tree Collapse file tree 3 files changed +9
-10
lines changed Original file line number Diff line number Diff line change 35
35
<url >http://spark.apache.org/</url >
36
36
37
37
<dependencies >
38
- <dependency >
39
- <groupId >org.apache.spark</groupId >
40
- <artifactId >spark-core_${scala.binary.version}</artifactId >
41
- <version >${project.version} </version >
42
- <type >test-jar</type >
43
- <scope >test</scope >
44
- </dependency >
45
38
<dependency >
46
39
<groupId >org.apache.commons</groupId >
47
40
<artifactId >commons-lang3</artifactId >
Original file line number Diff line number Diff line change @@ -31,10 +31,9 @@ import org.apache.flume.Context
31
31
import org .apache .flume .channel .MemoryChannel
32
32
import org .apache .flume .event .EventBuilder
33
33
import org .jboss .netty .channel .socket .nio .NioClientSocketChannelFactory
34
+ import org .scalatest .FunSuite
34
35
35
- import org .apache .spark .SparkFunSuite
36
-
37
- class SparkSinkSuite extends SparkFunSuite {
36
+ class SparkSinkSuite extends FunSuite {
38
37
val eventsPerBatch = 1000
39
38
val channelCapacity = 5000
40
39
Original file line number Diff line number Diff line change 40
40
<artifactId >spark-core_${scala.binary.version}</artifactId >
41
41
<version >${project.version} </version >
42
42
</dependency >
43
+ <dependency >
44
+ <groupId >org.apache.spark</groupId >
45
+ <artifactId >spark-core_${scala.binary.version}</artifactId >
46
+ <version >${project.version} </version >
47
+ <type >test-jar</type >
48
+ <scope >test</scope >
49
+ </dependency >
43
50
<dependency >
44
51
<groupId >org.apache.spark</groupId >
45
52
<artifactId >spark-streaming_${scala.binary.version}</artifactId >
You can’t perform that action at this time.
0 commit comments