Зарегистрируйте класс в KRYO из командной строки scala

Когда я пытаюсь запустить команду из командной строки scala, я получаю следующую ошибку:

(TID 0, 192.168.20.81): java.lang.IllegalArgumentException:  

Class is not registered: scala.Tuple3[]    
Class is not registered: org.apache.spark.sql.Row[]

Note: To register this class use: kryo.register(scala.Tuple3[].class);
Note: To register this class use: kryo.register(org.apache.spark.sql.Row[].class);

Когда я запускаю «рекомендуемую» команду для регистрации класса, я получаю:

scala> kryo.register(scala.Tuple3[].class)
<console>:1: error: identifier expected but ']' found.
   kryo.register(scala.Tuple3[].class)

person mithrix    schedule 14.01.2016    source источник
comment
попробуйте kyro.register(classOf[Tuple3])   -  person Łukasz    schedule 14.01.2016
comment
scala› kyro.register(classOf[Tuple3]) ‹console›:51: ошибка: не найдено: значение kyro kyro.register(classOf[Tuple3])   -  person mithrix    schedule 14.01.2016
comment
Как бы я просто поместил это в spark-defaults.conf в параметре spark.kryo.classesToRegister   -  person mithrix    schedule 14.01.2016
comment
Google дал мне этот пример: stackoverflow.com/ вопросы/31394140/   -  person Łukasz    schedule 14.01.2016
comment
То есть для командной строки. Мне нужно поместить его в файл spark-default.conf.   -  person mithrix    schedule 14.01.2016
comment
просто перейдите по ссылкам там, приложите некоторые усилия: spark.apache .org/docs/latest/ на этой странице утверждается, что для ключа spark.kryo.classesToRegister вам следует указать. Если вы используете сериализацию Kryo, укажите разделенный запятыми список имен пользовательских классов для регистрации в Kryo. См. руководство по настройке для более подробной информации. Помните, что они должны быть полными именами   -  person Łukasz    schedule 14.01.2016
comment
Я уже просмотрел ссылки, которые вы перечислили, прежде чем публиковать здесь. Я уже внес изменения в файл spark-default.conf.   -  person mithrix    schedule 14.01.2016
comment
так в чем проблема на самом деле? В вашем вопросе у вас проблема с регистрацией класса в консоли, в ссылке, которую я вам дал, есть наглядный пример, как это сделать. Затем вы говорите, что вам нужно настроить файл .conf, что также объясняется в другой ссылке. Так что у тебя и в чем проблема?   -  person Łukasz    schedule 14.01.2016
comment
Один. Я обнаружил, что вы не можете зарегистрировать класс напрямую из консоли, а два класса, которые регистрируются через conf, не работают.   -  person mithrix    schedule 15.01.2016
comment
Значит conf.registerKryoClasses(Array(classOf[scala.Tuple3])) в консоли не работает? Вы получаете какую-либо ошибку? Что ты пишешь в конфу и как ты делаешь вывод, что это ошибка?   -  person Łukasz    schedule 15.01.2016
comment
Давайте продолжим это обсуждение в чате.   -  person mithrix    schedule 15.01.2016