ignite - 点火の例を実行できません

Question

ignite basic example を実行しようとしていますが、spark TaskNotSerializable エラーで失敗しています。私を助けてくれませんか。

val ignite = Ignition.start("/usr/local/ignite/config/example-ignite.xml");
val cfg = ignite.configuration() 
val ic = new IgniteContext[Integer, Integer](sc, () => cfg)
Ignition.setClientMode(true); 

val sharedRdd = ic.fromCache("example")
val x = sqlContext.sparkContext.parallelize(1 to 10000, 10).map(i => (new Integer(i), new Integer(i)))
sharedRdd.savePairs(x)

Answer 1

クラスがシリアライズ可能として実装されていない場合、スパークが原因で上記の例外も発生します。この例外を回避するには、クラスをシリアライズ可能にします (シリアライズ可能を実装します)。