You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2018/01/22 14:36:20 UTC

spark git commit: [SPARK-11630][CORE] ClosureCleaner moved from warning to debug

Repository: spark
Updated Branches:
  refs/heads/master 87ffe7add -> 4327ccf28


[SPARK-11630][CORE] ClosureCleaner moved from warning to debug

## What changes were proposed in this pull request?
ClosureCleaner moved from warning to debug
## How was this patch tested?
Existing tests

Author: Rekha Joshi <re...@gmail.com>
Author: rjoshi2 <re...@gmail.com>

Closes #20337 from rekhajoshm/SPARK-11630-1.


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/4327ccf2
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/4327ccf2
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/4327ccf2

Branch: refs/heads/master
Commit: 4327ccf289b5a0dc51f6294113d01af6eb52eea0
Parents: 87ffe7a
Author: Rekha Joshi <re...@gmail.com>
Authored: Mon Jan 22 08:36:17 2018 -0600
Committer: Sean Owen <so...@cloudera.com>
Committed: Mon Jan 22 08:36:17 2018 -0600

----------------------------------------------------------------------
 core/src/main/scala/org/apache/spark/util/ClosureCleaner.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/4327ccf2/core/src/main/scala/org/apache/spark/util/ClosureCleaner.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/util/ClosureCleaner.scala b/core/src/main/scala/org/apache/spark/util/ClosureCleaner.scala
index 4061642..ad0c063 100644
--- a/core/src/main/scala/org/apache/spark/util/ClosureCleaner.scala
+++ b/core/src/main/scala/org/apache/spark/util/ClosureCleaner.scala
@@ -207,7 +207,7 @@ private[spark] object ClosureCleaner extends Logging {
       accessedFields: Map[Class[_], Set[String]]): Unit = {
 
     if (!isClosure(func.getClass)) {
-      logWarning("Expected a closure; got " + func.getClass.getName)
+      logDebug(s"Expected a closure; got ${func.getClass.getName}")
       return
     }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org