Я пытался зарегистрировать класс Edge в Kryo, но всегда получаю следующую ошибку.
java.lang.IllegalArgumentException: Class is not registered: org.apache.spark.graphx.Edge\nNote: To register this class use: kryo.register(org.apache.spark.graphx.Edge.class);
что не так со следующей строкой?
sc.getConf.registerKryoClasses(Array(Class.forName("org.apache.spark.graphx.Edge")))
Как я должен это сделать?