Несоответствие версии Scala на Amazon EMR Flink

Question

Попытка запустить задание Flink (v 1.7.0) в Amazon EMR Flink (5.21.0).Я получаю исключение

java.lang.NoSuchMethodError: scala.Product.$init$(Lscala/Product;)V

Исключение выглядит как проблема версии SCALA.Я нашел библиотеки flink, там есть SCALA 2.11 и моя сборка работы с использованием 2.12.Flink 1.7.0 поддерживает SCALA 2.12.

Вопрос в том, как получить Amazon EMR с поддержкой SCALA 2.12 вместо 2.11?или есть ли лучшее решение, кроме моего кода, возвращающегося 2.11.

Answer 1

В документации есть описание *1002* того, как вручную установить любую версию Flink, которую вы хотите использовать с EMR.

Answer 2

EMR использует Flink 1.6.1, я считаю.Так что это версия, с которой вы хотите создать свой рабочий процесс Flink.