通过阅读有关 Apache Ignite 的文档，我的印象是，我在 Eclipse 中使用的（例如）类会自动（我敢说，神奇地？）发送到 Ignite 服务器的分布式实例。
我有 3 台香草服务器，没有加载运行的自定义类 (./bin/ignite.sh) ，都在本地主机上。他们很好地对视。
我运行一个带有一个自定义类的 Eclipse 程序，我用它来加载到缓存中。简单 POJO、Serializable 等
当我尝试运行一段计算代码时，远程服务器抱怨该类不在类加载器中。
Caused by: java.lang.ClassNotFoundException: com.company.dms.ignite.batch.model.MessageCustAccount
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:348)
at org.apache.ignite.internal.util.IgniteUtils.forName(IgniteUtils.java:8213)
at org.apache.ignite.internal.MarshallerContextAdapter.getClass(MarshallerContextAdapter.java:185)
at org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:607)
... 29 more
还有更多的魔法吗？
ExecutorService exec = ignite.executorService(ignite.cluster().forRemotes());
// Iterate through all words in the sentence and create jobs.
quickCounter = 10;
while(it.hasNext() && quickCounter-- > 0){// "Print words using runnable".split(" ")) {
final String word = it.next();
// Execute runnable on some node.
String interna_cache_name = DMSIgniteHelpers.getInstance().getCurrentCacheLocation(ignite, MSG_CUST_ACCT_CACHE);
exec.submit(new IgniteRunnable() {
@Override public void run() {
String delimeter = "\u0001";
String[] lineTokens = word.split("\\"+delimeter);
String three_pk = null;
if(lineTokens[2].toString() != null && lineTokens[4].toString() != null && lineTokens[3] != null) {
String sor_id = new Integer(lineTokens[2]).toString();
String cust_id = new Long(lineTokens[4]).toString();
String acct_id = lineTokens[3];
three_pk = sor_id + cust_id + acct_id;
System.out.println("Looking for ("+sor_id+") ("+cust_id+") ("+acct_id+") : " + three_pk + " ----- ");
System.out.println("Going to query cache: " + interna_cache_name);
IgniteCache<Integer, MessageCustAccount> msgCustAccountCache = ignite.cache(interna_cache_name);
MessageCustAccount a = sqlQuery(msgCustAccountCache,three_pk);
System.out.println("*************=================\n\n" + a.toString() + "\n@#$@#$@#$@#$@#$@#$@#$@#$@#$@#$@#$");
}
System.out.println(">>> Printing '" + word + "' on this node from grid job.");
}
});
}