Skip to content

Commit c807bf6

Browse files
author
maji2014
committed
Fix exception in SparkSinkSuite
1 parent 7b41b17 commit c807bf6

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

external/flume-sink/src/test/scala/org/apache/spark/streaming/flume/sink/SparkSinkSuite.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -159,6 +159,7 @@ class SparkSinkSuite extends FunSuite {
159159
channelContext.put("transactionCapacity", 1000.toString)
160160
channelContext.put("keep-alive", 0.toString)
161161
channelContext.putAll(overrides)
162+
channel.setName(getClass.getDeclaredMethods.toString)
162163
channel.configure(channelContext)
163164

164165
val sink = new SparkSink()

0 commit comments

Comments
 (0)