Я запустил следующий код:
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
Мой финалФайл, который я использовал для сохранения своих данных в коде, пуст.
Как я могу решить эту проблему?программа сделала правильный файл в правильном каталоге, но он пуст