Spark (Scala): имя атрибута содержит недопустимый символ

Пытаясь записать DataFrame в HDFS, я столкнулся со следующей проблемой:

  org.apache.spark.sql.AnalysisException: Attribute name " "someName1"" contains invalid character(s) among " ,;{}()\n\t = ". Please use alias to rename it.;

Источником для DataFrame является csv-файл:

       "value_hash", "someName1"
       79000000000, name1
       79000000000, name2

Этот csv прочитан:

    val dataFrame = SparkSession.read.option("header", "true").csv(path) 

Затем я выбираю и привожу типы для этого dataFrame:

   def castColumn(colName: String, colType: String): Column = col(colName).cast(DataType.fromJson(colType))

val featureColumns: Seq[(PathString, String)] = dataFrame.columns.tail.map(f=>(f, "\"string\"")).toSeq

val columns = (schema ++ featureColumns).
  map { case (colName, colType) => castColumn(colName, colType) }
dataFrame.select(columns.toSeq: _*)

где схема имеет тип: Map[String, String] и имеет значение по умолчанию Map("value_hash" -> ""string"")

В этом коде я добавляю схему featureColumns к схеме по умолчанию (поскольку я не знал полной исходной схемы - она ​​создавалась динамически после чтения csv из hdfs).

Затем я пытаюсь записать этот DataFrame в hdfs-path:

  dataFrame
      .repartition(1)
      .write
      .parquet(outputPath)

Следуя рекомендации в сообщении об ошибке, я попытался использовать псевдоним для каждого столбца, поэтому:

 filteredRemove.columns.foreach{
  ca=>filteredRemove.select(col(ca).alias(ca)))
}
 

и так:

filteredRemove.columns.foreach{
  ca=>filteredRemove.select(col(ca).alias(ca)).show()
}

Но результат был тот же: org.apache.spark.sql.AnalysisException...

Замечает пробелы и кавычки в ""someName1"", я также пытался очистить псевдоним от этого:

 filteredRemove.columns.foreach{
  ca=>filteredRemove.select(col(ca).alias(ca.trim.substring(0,ca.length-1))).show()
}

Но без какого-либо результата. Я все еще сталкиваюсь с исключением, которое показано выше.

Что я делаю не так?