Spark＆Drools - KryoでKieBaseをシリアライズする方法

Question

SparkのKieBaseオブジェクトをシリアル化しようとしている例外で実行しています。

私は次のコードを実行する： java.util.ConcurrentModificationExceptionが

：

val kieBase = kieContainer.getKieBase 
val broadcastKieBase = spark.sparkContext.broadcast(kieBase) 

をConcurrentModificationExceptionがスレッド "メイン" com.esotericsoftware.kryo.KryoExceptionで

例外が発生しています

私もthis is a known problemでしたが、解決策はありませんでした。

KieBaseインスタンスをKryoでシリアル化する方法は誰でも知っていますか？

Answer 1

KieBaseはシリアル化できません。代わりに、シングルトンクラスを作成して、エグゼキュータにKieBaseを挿入します。各エグゼキュータは独自のインスタンスを持ちます。