Fixed small bug

maropu · Jun 9, 2015 · d388f86 · d388f86
1 parent c4e3bf5
commit d388f86
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/api/r/SQLUtils.scala b/sql/core/src/main/scala/org/apache/spark/sql/api/r/SQLUtils.scala
@@ -44,7 +44,7 @@ private[r] object SQLUtils {
   }
 
   def createStructField(name: String, dataType: String, nullable: Boolean): StructField = {
-    val dtObj = DataType.fromString(dataType)
+    val dtObj = DataTypeParser.parse(dataType)
     StructField(name, dtObj, nullable)
   }