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嵌入執行器中。每個執行者都有自己的實例。