Fix exception in SparkSinkSuite

apache · Nov 9, 2014 · c807bf6 · c807bf6
1 parent 7b41b17
commit c807bf6
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...rnal/flume-sink/src/test/scala/org/apache/spark/streaming/flume/sink/SparkSinkSuite.scala b/...rnal/flume-sink/src/test/scala/org/apache/spark/streaming/flume/sink/SparkSinkSuite.scala
@@ -159,6 +159,7 @@ class SparkSinkSuite extends FunSuite {
     channelContext.put("transactionCapacity", 1000.toString)
     channelContext.put("keep-alive", 0.toString)
     channelContext.putAll(overrides)
+    channel.setName(getClass.getDeclaredMethods.toString)
     channel.configure(channelContext)
 
     val sink = new SparkSink()