1
這個錯誤是什麼意思?我試圖從Apache Spark映射函數中檢索Ignite緩存。Ignite grid name線程本地必須設置,或者這個方法應該在org.apache.ignite.thread.IgniteThread下訪問
我在這裏錯過了什麼嗎?
這個錯誤是什麼意思?我試圖從Apache Spark映射函數中檢索Ignite緩存。Ignite grid name線程本地必須設置,或者這個方法應該在org.apache.ignite.thread.IgniteThread下訪問
我在這裏錯過了什麼嗎?
最可能的是Ignite
或IgniteCache
實例被序列化並隨功能一起發送到執行程序。您應該避免這種情況,並使用Ignition
在本地獲得Ignite
。
澄清:
點燃例可以成功反序列化在點燃線程的上下文,所以在Ignite計算它工作正常。但在這種情況下,它是Spark並將Ignite發送給執行者是錯誤的。事實上,它不能保證它存在於那裏,所以我們應該總是使用Ignition來正確地獲取或創建Spark執行器上的客戶端節點。
這正是發生了什麼事。 Ignite被序列化。謝謝。 –