You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2014/06/30 08:29:08 UTC
git commit: SPARK-2077 Log serializer that actually ends up being used
Repository: spark
Updated Branches:
refs/heads/master a484030da -> 680364225
SPARK-2077 Log serializer that actually ends up being used
I could settle with this being a debug also if we provided an example of how to turn it on in `log4j.properties`
https://issues.apache.org/jira/browse/SPARK-2077
Author: Andrew Ash <an...@andrewash.com>
Closes #1017 from ash211/SPARK-2077 and squashes the following commits:
580f680 [Andrew Ash] Drop to debug
0266415 [Andrew Ash] SPARK-2077 Log serializer that actually ends up being used
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/68036422
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/68036422
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/68036422
Branch: refs/heads/master
Commit: 6803642253b45c80ef8970606e350adabe4211ea
Parents: a484030
Author: Andrew Ash <an...@andrewash.com>
Authored: Sun Jun 29 23:29:05 2014 -0700
Committer: Reynold Xin <rx...@apache.org>
Committed: Sun Jun 29 23:29:05 2014 -0700
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/SparkEnv.scala | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/68036422/core/src/main/scala/org/apache/spark/SparkEnv.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/SparkEnv.scala b/core/src/main/scala/org/apache/spark/SparkEnv.scala
index 8dfa8cc..2b636b0 100644
--- a/core/src/main/scala/org/apache/spark/SparkEnv.scala
+++ b/core/src/main/scala/org/apache/spark/SparkEnv.scala
@@ -183,6 +183,7 @@ object SparkEnv extends Logging {
val serializer = instantiateClass[Serializer](
"spark.serializer", "org.apache.spark.serializer.JavaSerializer")
+ logDebug(s"Using serializer: ${serializer.getClass}")
val closureSerializer = instantiateClass[Serializer](
"spark.closure.serializer", "org.apache.spark.serializer.JavaSerializer")