From 312620a235d6b79dba2a222ae8455f9d4fc6d1b5 Mon Sep 17 00:00:00 2001 From: maji2014 Date: Mon, 10 Nov 2014 21:27:33 -0800 Subject: [PATCH] change a new statement for spark-4295 --- .../org/apache/spark/streaming/flume/sink/SparkSinkSuite.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 6a60d814643aa..650b2fbe1c142 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,7 +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.setName(scala.util.Random.nextString(10)) channel.configure(channelContext) val sink = new SparkSink()