diff --git a/external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumePollingStreamSuite.scala b/external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumePollingStreamSuite.scala index d8d5bc6d38537..488a0b1f827f0 100644 --- a/external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumePollingStreamSuite.scala +++ b/external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumePollingStreamSuite.scala @@ -68,7 +68,7 @@ class FlumePollingStreamSuite extends TestSuiteBase { testPassed = true } catch { case e: java.net.BindException => - logError("Exception when running flume polling test", e) + logWarning("Exception when running flume polling test: " + e) attempt += 1 } }