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 2015/01/10 05:38:55 UTC
spark git commit: [SPARK-5141][SQL]CaseInsensitiveMap throws
java.io.NotSerializableException
Repository: spark
Updated Branches:
refs/heads/master 4554529dc -> 545dfcb92
[SPARK-5141][SQL]CaseInsensitiveMap throws java.io.NotSerializableException
CaseInsensitiveMap throws java.io.NotSerializableException.
Author: luogankun <lu...@gmail.com>
Closes #3944 from luogankun/SPARK-5141 and squashes the following commits:
b6d63d5 [luogankun] [SPARK-5141]CaseInsensitiveMap throws java.io.NotSerializableException
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/545dfcb9
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/545dfcb9
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/545dfcb9
Branch: refs/heads/master
Commit: 545dfcb92f2ff82a51877d35d9669094ea81f466
Parents: 4554529
Author: luogankun <lu...@gmail.com>
Authored: Fri Jan 9 20:38:41 2015 -0800
Committer: Reynold Xin <rx...@databricks.com>
Committed: Fri Jan 9 20:38:41 2015 -0800
----------------------------------------------------------------------
sql/core/src/main/scala/org/apache/spark/sql/sources/ddl.scala | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/545dfcb9/sql/core/src/main/scala/org/apache/spark/sql/sources/ddl.scala
----------------------------------------------------------------------
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/sources/ddl.scala b/sql/core/src/main/scala/org/apache/spark/sql/sources/ddl.scala
index 8a66ac3..364bace 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/sources/ddl.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/sources/ddl.scala
@@ -110,7 +110,8 @@ private[sql] case class CreateTableUsing(
/**
* Builds a map in which keys are case insensitive
*/
-protected class CaseInsensitiveMap(map: Map[String, String]) extends Map[String, String] {
+protected class CaseInsensitiveMap(map: Map[String, String]) extends Map[String, String]
+ with Serializable {
val baseMap = map.map(kv => kv.copy(_1 = kv._1.toLowerCase))
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org