diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/ScriptTransformation.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/ScriptTransformation.scala index f6e6a75c3ee5..857de5bc50d8 100644 --- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/ScriptTransformation.scala +++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/ScriptTransformation.scala @@ -178,7 +178,7 @@ case class ScriptTransformation( curLine = reader.readLine() if (!ioschema.schemaLess) { new GenericInternalRow( - prevLine.split(ioschema.outputRowFormatMap("TOK_TABLEROWFORMATFIELD")) + prevLine.split(ioschema.outputRowFormatMap("TOK_TABLEROWFORMATFIELD"), -1) .map(CatalystTypeConverters.convertToCatalyst)) } else { new GenericInternalRow(