2016-09-23 23 views
1

私はSpark 1.6.0-cdh5.8.0を使用しています。Spark Kryo例外 - クラスが登録されていません:com.google.common.base.Present

私はKryoを使用しようとしています。私はそれがスパークが使用していたと思ったので、オプションのグアバを持っています。

しかし、現在のクラスにはデフォルトの可視性があるので、Kryoを使ってそれをシリアル化することはできません。

だから誰もがこれを見つけて解決しました。

プレゼントが隠されているので、次のコードは動作しません...

kryo.register(com.google.common.base.Present.class) 

答えて

1

試してみてください。

kryo.register(Class.forName("com.google.common.base.Present")) 
関連する問題