2017-04-18 60 views
2

我是新來點燃並試圖運行我的簡單多節點計算示例。我寫了下面的簡單應用:我們需要ignite.sh腳本?

try(Ignite ignite = Ignition.start("example-cache.xml")){ 
     IgniteCompute asyncCompute = ignite.compute().withAsync(); 
     for(int i = 0; i < 100; i++) { 
      int[] a = new int[1]; 
      a[0] = i; 
      asyncCompute.call(() -> { 
       out.println(a[0]); 
       return a[0]; 
      }); 
     } 
} 

首先,我跑了3個服務器節點與與二進制點燃分佈提供ignite.sh。每個在不同的JVM實例中。

然後我構建這個應用程序並使用與以前的3個服務器節點相同的xml-spring配置運行它。

但實際上我有以下異常:

class org.apache.ignite.IgniteCheckedException: com.test.App 
     at org.apache.ignite.internal.util.IgniteUtils.unmarshal(IgniteUtils.java:9826) 
     at org.apache.ignite.internal.processors.job.GridJobWorker.initialize(GridJobWorker.java:432) 
     at org.apache.ignite.internal.processors.job.GridJobProcessor.processJobExecuteRequest(GridJobProcessor.java:1108) 
     at org.apache.ignite.internal.processors.job.GridJobProcessor$JobExecutionListener.onMessage(GridJobProcessor.java:1894) 
     at org.apache.ignite.internal.managers.communication.GridIoManager.invokeListener(GridIoManager.java:1222) 
     at org.apache.ignite.internal.managers.communication.GridIoManager.processRegularMessage0(GridIoManager.java:850) 
     at org.apache.ignite.internal.managers.communication.GridIoManager.access$2100(GridIoManager.java:108) 
     at org.apache.ignite.internal.managers.communication.GridIoManager$7.run(GridIoManager.java:790) 
     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 
     at java.lang.Thread.run(Thread.java:745) 
Caused by: class org.apache.ignite.binary.BinaryInvalidTypeException: com.test.App 
     at org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:692) 
     at org.apache.ignite.internal.binary.BinaryUtils.doReadClass(BinaryUtils.java:1486) 
     at org.apache.ignite.internal.binary.BinaryUtils.doReadClass(BinaryUtils.java:1424) 
     at org.apache.ignite.internal.binary.BinaryReaderExImpl.readClass(BinaryReaderExImpl.java:370) 
     at org.apache.ignite.internal.binary.BinaryFieldAccessor$DefaultFinalClassAccessor.readFixedType(BinaryFieldAccessor.java:828) 
     at org.apache.ignite.internal.binary.BinaryFieldAccessor$DefaultFinalClassAccessor.read(BinaryFieldAccessor.java:639) 
     at org.apache.ignite.internal.binary.BinaryClassDescriptor.read(BinaryClassDescriptor.java:833) 
     at org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize0(BinaryReaderExImpl.java:1498) 
     at org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize(BinaryReaderExImpl.java:1450) 
     at org.apache.ignite.internal.binary.BinaryUtils.doReadObject(BinaryUtils.java:1640) 
     at org.apache.ignite.internal.binary.BinaryReaderExImpl.readObject(BinaryReaderExImpl.java:1124) 
     at org.apache.ignite.internal.processors.closure.GridClosureProcessor$C2V2.readBinary(GridClosureProcessor.java:2073) 
     at org.apache.ignite.internal.binary.BinaryClassDescriptor.read(BinaryClassDescriptor.java:823) 
     at org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize0(BinaryReaderExImpl.java:1498) 
     at org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize(BinaryReaderExImpl.java:1450) 
     at org.apache.ignite.internal.binary.GridBinaryMarshaller.deserialize(GridBinaryMarshaller.java:298) 
     at org.apache.ignite.internal.binary.BinaryMarshaller.unmarshal0(BinaryMarshaller.java:99) 
     at org.apache.ignite.marshaller.AbstractNodeNameAwareMarshaller.unmarshal(AbstractNodeNameAwareMarshaller.java:82) 
     at org.apache.ignite.internal.util.IgniteUtils.unmarshal(IgniteUtils.java:9820) 
     ... 10 more 
Caused by: java.lang.ClassNotFoundException: com.test.App 
     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:8459) 
     at org.apache.ignite.internal.MarshallerContextAdapter.getClass(MarshallerContextAdapter.java:185) 
     at org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:683) 

這個例外是非常清楚。但是我們需要什麼ignite.sh腳本?

回答

1

您應該將JAR文件Apache的點燃安裝文件夾下添加到lib /文件夾。然後你可以啓動ignite.sh,所有的類都會自動加載。

或者,您可以嘗試啓用上面建議的peer-class-loading,並且Ignite將自動加載這些類。

+0

謝謝你的建議。但推薦的方式是什麼? –

+0

取決於您的要求。在開發中,我肯定會建議打開對等類加載,因爲它可以爲您節省大量的部署時間。如果遇到問題,請切換到JAR部署。 – Dmitriy