diff options
| author | luogankun <luogankun@gmail.com> | 2015-01-09 20:38:41 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-01-09 20:38:41 -0800 |
| commit | 545dfcb92f2ff82a51877d35d9669094ea81f466 (patch) | |
| tree | 4ee0ab754dc25461dc8adbd27677f33e4427a977 /sql/core | |
| parent | 4554529dce8fe8ca937d887109ef072eef52bf51 (diff) | |
| download | spark-545dfcb92f2ff82a51877d35d9669094ea81f466.tar.gz spark-545dfcb92f2ff82a51877d35d9669094ea81f466.tar.bz2 spark-545dfcb92f2ff82a51877d35d9669094ea81f466.zip | |
[SPARK-5141][SQL]CaseInsensitiveMap throws java.io.NotSerializableException
CaseInsensitiveMap throws java.io.NotSerializableException.
Author: luogankun <luogankun@gmail.com>
Closes #3944 from luogankun/SPARK-5141 and squashes the following commits:
b6d63d5 [luogankun] [SPARK-5141]CaseInsensitiveMap throws java.io.NotSerializableException
Diffstat (limited to 'sql/core')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/sources/ddl.scala | 3 |
1 files changed, 2 insertions, 1 deletions
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 8a66ac31f2..364bacec83 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)) |