Я пытаюсь использовать ноутбук Zeppelin с интерпретатором% livy.spark для Ignite.У меня есть следующий код:
%livy.spark
import java.lang.{Long ⇒ JLong, String ⇒ JString}
import scala.collection.JavaConversions._
import org.apache.ignite.cache.query.SqlFieldsQuery
Этот код отлично работает, когда я использую интерпретатор %flink
, но когда я использую %livy.spark
, он выдает:
error: object ignite is not a member of package org.apache
import _root_.org.apache.ignite.cache.query.SqlFieldsQuery
Livy настроенправильно, когда я использую %livy.pyspark
в ноутбуке Python Zeppelin Notebook, он работает нормально.
Итак, вопрос, что вызывает ошибку при использовании %livy.spark
специально для Scala Zeppelin Notebook?