Apache Ignite：Classloader

从阅读关于Apache Ignite的文档，我的印象是，我在Eclipse中使用的类（例如）会自动发送到Ignite服务器的分布式实例。Apache Ignite：Classloader

我有3个香草服务器，没有自定义的类加载运行（./bin/ignite.sh），都在本地主机上。他们同行非常好。

我运行一个Eclipse程序时使用了一个用于加载到缓存中的自定义类。简单的POJO，可序列化等。

当我尝试运行一段计算代码时，远程服务器抱怨类不在类加载器中。

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() + "\[email protected]#[email protected]#[email protected]#[email protected]#[email protected]#[email protected]#[email protected]#[email protected]#[email protected]#[email protected]#[email protected]#$"); 

        } 
       System.out.println(">>> Printing '" + word + "' on this node from grid job."); 
      } 
      }); 
     }