Апачская Искра со Скалой - PullRequest
0 голосов
/ 12 декабря 2018

Я запустил следующий код:

object AirportsInUsaSolution {

  def main(args: Array[String]) {

    val conf = new SparkConf().setAppName("airports").setMaster("local[2]")
    val sc = new SparkContext(conf)

    val airports = sc.textFile("in/airports.text")
    val airportsInUSA = airports.filter(line => line.split(Utils.COMMA_DELIMITER)(3) == "\"United States\"")

    val airportsNameAndCityNames = airportsInUSA.map(line => {
      val splits = line.split(Utils.COMMA_DELIMITER)
      splits(1) + ", " + splits(2)
    })
    airportsNameAndCityNames.saveAsTextFile("out/airports_in_usa.text")
  }
}

И получил следующее сообщение об ошибке:

Процесс завершен с кодом выхода 1

Мой финалФайл, который я использовал для сохранения своих данных в коде, пуст.

Как я могу решить эту проблему?программа сделала правильный файл в правильном каталоге, но он пуст

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...