Hello! I think you are affected by https://issues.apache.org/jira/browse/IGNITE-9054 which is being worked on.
Regards, -- Ilya Kasnacheev чт, 30 авг. 2018 г. в 11:47, Serty J <[email protected]>: > Hello Danis, > Thanks for your reply, but SqlQuery is working fine, is there any > difference in P2P class loading mechanism between SqlQuery and ScanQuery? > Thanks > Saby > > On Thu, Aug 30, 2018 at 1:44 PM Denis Mekhanikov <[email protected]> > wrote: > >> The client protocol doesn't imply P2P class loading. >> So, you need to provide the implementation of the scan query on the >> server side. >> P2P class loading works only for regular nodes, server or client as well. >> >> Denis >> >> чт, 30 авг. 2018 г. в 9:14, Saby <[email protected]>: >> >>> ScanQuery is reporting the following exception while trying to fetch the >>> data >>> from remote Ignite Server through the Java thing client keeping the >>> peerClassLoading is enabled, But SqlQuery is fetching the correct result >>> and >>> is sending it back to the client. >>> If Lamda expression is used as filter in the ScanQuery then Ignite Server >>> reporting "java.lang.IllegalArgumentException: Invalid lambda >>> deserialization" >>> >>> Is there any way to use ScanQuery to fetch data from remote server using >>> Thin Client without copying jar(s) to the remote server(s)? >>> >>> public class Predicate<K,V> implements IgniteBiPredicate<K,V> >>> { >>> public boolean apply(K e1, V e2) { >>> return true; >>> } >>> } >>> >>> >>> [10:48:39,126][SEVERE][client-connector-#65][ClientListenerNioListener] >>> Failed to process client request >>> >>> [req=o.a.i.i.processors.platform.client.cache.ClientCacheScanQueryRequest@504d875d >>> ] >>> class org.apache.ignite.binary.BinaryInvalidTypeException: >>> XXX.datamigration.imdg.abstractionlayer.connections.impl.ignite.Predicate >>> at >>> >>> org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:697) >>> at >>> >>> org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize0(BinaryReaderExImpl.java:1755) >>> at >>> >>> org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize(BinaryReaderExImpl.java:1714) >>> at >>> >>> org.apache.ignite.internal.binary.BinaryObjectImpl.deserializeValue(BinaryObjectImpl.java:798) >>> at >>> >>> org.apache.ignite.internal.binary.BinaryObjectImpl.deserialize(BinaryObjectImpl.java:640) >>> at >>> >>> org.apache.ignite.internal.processors.platform.client.cache.ClientCacheScanQueryRequest.createFilter(ClientCacheScanQueryRequest.java:126) >>> at >>> >>> org.apache.ignite.internal.processors.platform.client.cache.ClientCacheScanQueryRequest.process(ClientCacheScanQueryRequest.java:92) >>> at >>> >>> org.apache.ignite.internal.processors.platform.client.ClientRequestHandler.handle(ClientRequestHandler.java:57) >>> at >>> >>> org.apache.ignite.internal.processors.odbc.ClientListenerNioListener.onMessage(ClientListenerNioListener.java:160) >>> at >>> >>> org.apache.ignite.internal.processors.odbc.ClientListenerNioListener.onMessage(ClientListenerNioListener.java:44) >>> at >>> >>> org.apache.ignite.internal.util.nio.GridNioFilterChain$TailFilter.onMessageReceived(GridNioFilterChain.java:279) >>> at >>> >>> org.apache.ignite.internal.util.nio.GridNioFilterAdapter.proceedMessageReceived(GridNioFilterAdapter.java:109) >>> at >>> >>> org.apache.ignite.internal.util.nio.GridNioAsyncNotifyFilter$3.body(GridNioAsyncNotifyFilter.java:97) >>> at >>> >>> org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110) >>> at >>> >>> org.apache.ignite.internal.util.worker.GridWorkerPool$1.run(GridWorkerPool.java:70) >>> at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown >>> Source) >>> at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown >>> Source) >>> at java.lang.Thread.run(Unknown Source) >>> Caused by: java.lang.ClassNotFoundException: >>> XXX.datamigration.imdg.abstractionlayer.connections.impl.ignite.Predicate >>> at java.net.URLClassLoader.findClass(Unknown Source) >>> at java.lang.ClassLoader.loadClass(Unknown Source) >>> at sun.misc.Launcher$AppClassLoader.loadClass(Unknown Source) >>> at java.lang.ClassLoader.loadClass(Unknown Source) >>> at java.lang.Class.forName0(Native Method) >>> at java.lang.Class.forName(Unknown Source) >>> at >>> >>> org.apache.ignite.internal.util.IgniteUtils.forName(IgniteUtils.java:8608) >>> at >>> >>> org.apache.ignite.internal.MarshallerContextImpl.getClass(MarshallerContextImpl.java:349) >>> at >>> >>> org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:688) >>> >>> >>> >>> >>> -- >>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/ >>> >>
