这个错误是什么意思?我正在尝试从Apache Spark映射函数中检索Ignite缓存。
我在这里想念什么吗?
最佳答案
Ignite
或IgniteCache
实例很可能已被序列化,并与函数一起发送给执行程序。您应该避免这种情况,并使用Ignite
在本地获取Ignition
。
澄清:
Ignite实例可以在Ignite线程的上下文中成功反序列化,因此使用Ignite计算可以正常工作。但是在这种情况下是Spark并且将Ignite发送给执行者是错误的。实际上,不能保证它甚至在那里都存在,因此应该始终使用Ignition在Spark执行器上正确获取或创建客户端节点。
关于java - 必须设置Ignite网格名称线程本地,否则应在org.apache.ignite.thread.IgniteThread下访问此方法,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/43545956/