我一直试图注册边缘类与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")))
我该怎么做?
暂无答案!
目前还没有任何答案,快来回答吧!