Remove debug statements

streaming/src/main/scala/spark/streaming/util/MasterFailureTest.scala

@@ -74,7 +74,6 @@ object MasterFailureTest extends Logging {
 
     val operation = (st: DStream[String]) => {
       val updateFunc = (values: Seq[Long], state: Option[Long]) => {
-        logInfo("UpdateFunc .. state = " + state.getOrElse(0L) + ", values = " + values)
         Some(values.foldLeft(0L)(_ + _) + state.getOrElse(0L))
       }
       st.flatMap(_.split(" "))

streaming/src/test/scala/spark/streaming/FailureSuite.scala

@@ -22,12 +22,10 @@ class FailureSuite extends FunSuite with BeforeAndAfter with Logging {
   val batchDuration = Milliseconds(1000)
 
   before {
-    logInfo("BEFORE ...")
     FileUtils.deleteDirectory(new File(directory))
   }
 
   after {
-    logInfo("AFTER ...")
     FileUtils.deleteDirectory(new File(directory))
   }