fix test

Davies Liu · Davies Liu · commit de986d63e4cb · 2015-07-17T00:12:19.000-07:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/types/DataType.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/types/DataType.scala
@@ -144,13 +144,13 @@ object DataType {
 
     case JSortedObject(
     ("class", JString(udtClass)),
-    ("pyClass", JString(pyClass)),
+    ("pyClass", pyClass: JValue),  // pyClass could be null, cannot match with JString()
     ("sqlType", v: JValue),
     ("type", JString("udt"))) =>
       if (udtClass.length > 0) {
         Utils.classForName(udtClass).newInstance().asInstanceOf[UserDefinedType[_]]
       } else {
-        new PythonUserDefinedType(parseDataType(v), pyClass)
+        new PythonUserDefinedType(parseDataType(v), pyClass.asInstanceOf[JString].values)
       }
   }
 

Original file line number	Diff line number	Diff line change
`@@ -144,13 +144,13 @@ object DataType {`
`144`	`144`
`145`	`145`	`case JSortedObject(`
`146`	`146`	`("class", JString(udtClass)),`
`147`		`- ("pyClass", JString(pyClass)),`
	`147`	`+ ("pyClass", pyClass: JValue), // pyClass could be null, cannot match with JString()`
`148`	`148`	`("sqlType", v: JValue),`
`149`	`149`	`("type", JString("udt"))) =>`
`150`	`150`	`if (udtClass.length > 0) {`
`151`	`151`	`Utils.classForName(udtClass).newInstance().asInstanceOf[UserDefinedType[_]]`
`152`	`152`	`} else {`
`153`		`- new PythonUserDefinedType(parseDataType(v), pyClass)`
	`153`	`+ new PythonUserDefinedType(parseDataType(v), pyClass.asInstanceOf[JString].values)`
`154`	`154`	`}`
`155`	`155`	`}`
`156`	`156`