RowFactory.Create создает исключение

Question

Я пытаюсь изменить мой JavaRDD из String на JavaRDD из Row.На шаге я меняю строку на строку.Программа всегда давит.

 JavaRDD<String> lines = jsc.parallelize(row_string);
 JavaRDD<Row> rdd =  lines.map(new Function<String, Row>() {
 private static final long serialVersionUID = 1L;
 @Override
 public Row call(String line) {
       String[] split = line.split(",");
       System.out.println(split.length);
       return RowFactory.create(Arrays.asList(split));
     }
 });

Может кто-нибудь указать, где я ошибаюсь?