Spark 2.0.0 Arrays.asList не работает - несовместимые типы

Следующий код работает со Spark 1.5.2, но не со Spark 2.0.0. Я использую Java 1.8.

final SparkConf sparkConf = new SparkConf();
sparkConf.setMaster("local[4]"); // Four threads
final JavaSparkContext javaSparkContext = new JavaSparkContext(sparkConf);
final JavaRDD<String> javaRDDLines = javaSparkContext.textFile("4300.txt");
final JavaRDD<String> javaRDDWords = javaRDDLines.flatMap(line -> Arrays.asList(line.split(" ")));

Я получаю следующую ошибку

Error:(46, 66) java: incompatible types: no instance(s) of type variable(s) T exist so that java.util.List<T> conforms to java.util.Iterator<U>

Я не могу понять, изменился ли Spark API или что-то еще. Пожалуйста помоги. Благодарю.

Ответы на вопрос(1)

Ваш ответ на вопрос