Spark＆Drools - 如何用Kryo序列化KieBase

Question

我在异常中运行，试图序列化Spark中的KieBase对象。

当我执行以下代码：

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

甲ConcurrentModificationException升高在螺纹

异常 “主” com.esotericsoftware.kryo.KryoException： java.util.ConcurrentModificationException

环顾四周，我发现this is a known problem，但仍然没有解决方案。

任何人都知道如何使用Kryo序列化一个KieBase实例？

Answer 1

KieBase不能被序列化。相反，创建一个单例类并将KieBase嵌入执行器中。每个执行者都有自己的实例。