Когда я пытаюсь запустить команду из командной строки 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)
conf.registerKryoClasses(Array(classOf[scala.Tuple3]))
в консоли не работает? Вы получаете какую-либо ошибку? Что ты пишешь в конфу и как ты делаешь вывод, что это ошибка? - person Łukasz   schedule 15.01.2016