From 430c531464a5372237c97394f8f4b6ec344394c0 Mon Sep 17 00:00:00 2001
From: Mridul Muralidharan <mridul@gmail.com>
Date: Mon, 29 Apr 2013 00:24:30 +0530
Subject: [PATCH] Remove debug statements
---
.../src/main/scala/spark/streaming/util/MasterFailureTest.scala | 1 -
streaming/src/test/scala/spark/streaming/FailureSuite.scala | 2 --
2 files changed, 3 deletions(-)
diff --git a/streaming/src/main/scala/spark/streaming/util/MasterFailureTest.scala b/streaming/src/main/scala/spark/streaming/util/MasterFailureTest.scala
index e7a3f92bc0..426a9b6f71 100644
--- a/streaming/src/main/scala/spark/streaming/util/MasterFailureTest.scala
+++ b/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(" "))
diff --git a/streaming/src/test/scala/spark/streaming/FailureSuite.scala b/streaming/src/test/scala/spark/streaming/FailureSuite.scala
index 4529e774e9..a5fa7ab92d 100644
--- a/streaming/src/test/scala/spark/streaming/FailureSuite.scala
+++ b/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))
}
--
GitLab