Я создаю искровую сессию через LivyClient. Код для создания сеанса -
var client: LivyClient = null
try {
client = new LivyClientBuilder()
.setURI(new URI("http://127.0.0.1:4141"))
.build();
val pi = client.submit(new FileStream()).get
} finally {
client.stop(true)
}
При создании сеанса я получаю сообщение об ошибке -
Исключение в потоке main scala.reflect.internal.FatalError: объект Predef не имеет члена classOf введите изображение описание здесь
Я использую следующие версии -
- Apache Livy - 0.5.0-инкубатор
- Apache Spark - 2.3.0
- Scala - 2.11 (2.11.8)
Я проверил версию scala-reflection во всех трех, и они одинаковы.
Я не могу понять, что вызывает указанную ниже ошибку
client.submit
метод - person morsik   schedule 22.11.2018