From c807bf66a8d945708af0f620576255cc133ffe46 Mon Sep 17 00:00:00 2001 From: maji2014 Date: Sun, 9 Nov 2014 07:58:50 -0800 Subject: [PATCH] Fix exception in SparkSinkSuite --- .../org/apache/spark/streaming/flume/sink/SparkSinkSuite.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/external/flume-sink/src/test/scala/org/apache/spark/streaming/flume/sink/SparkSinkSuite.scala b/external/flume-sink/src/test/scala/org/apache/spark/streaming/flume/sink/SparkSinkSuite.scala index a2b2cc6149d95..6a60d814643aa 100644 --- a/external/flume-sink/src/test/scala/org/apache/spark/streaming/flume/sink/SparkSinkSuite.scala +++ b/external/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()