Error while using query in hazelcast

gsgovin...@gmail.com

unread,

Jan 15, 2015, 6:24:16 AM1/15/15

to haze...@googlegroups.com

public class IndexDemo2 {

public static void main(String[] args) throws Exception {

final HazelcastInstance hz = Hazelcast.newHazelcastInstance(null);

final IMap map = hz.getMap("test");

map.addIndex( "something", true );

map.put(1, new MyObj(2, new AnotherObject("value1")));

map.put(2, new MyObj(2, new AnotherObject("value2")));

map.put(3, new MyObj(3, new AnotherObject("akk3")));

Collection<MyObj>aa=map.values(new SqlPredicate("something > 1 and complexMember.someString like 'val%'"));

System.out.println(aa.size());

hz.shutdown();

}}

class MyObj implements Serializable {

private int something;

private AnotherObject complexMember;

MyObj(final int something, final AnotherObject complexMember) {

this.something = something;

this.complexMember = complexMember;

}

class AnotherObject implements Serializable {

private String someString;

AnotherObject(final String someString) {

this.someString = someString;

}

When i put 2 objects it works fine. But when I put more than 2 it gives me error.

Exception in thread "main" com.hazelcast.nio.serialization.HazelcastSerializationException: java.lang.ClassNotFoundException: MyObj

at com.hazelcast.nio.serialization.DefaultSerializers$ObjectSerializer.read(DefaultSerializers.java:201)

at com.hazelcast.nio.serialization.StreamSerializerAdapter.toObject(StreamSerializerAdapter.java:65)

at com.hazelcast.nio.serialization.SerializationServiceImpl.toObject(SerializationServiceImpl.java:260)

at com.hazelcast.query.impl.QueryEntry.getValue(QueryEntry.java:62)

at com.hazelcast.query.impl.QueryEntry.getAttributeType(QueryEntry.java:140)

at com.hazelcast.query.impl.IndexImpl.saveEntryIndex(IndexImpl.java:83)

at com.hazelcast.query.impl.IndexService.saveEntryIndex(IndexService.java:74)

at com.hazelcast.map.impl.AbstractRecordStore.saveIndex(AbstractRecordStore.java:143)

at com.hazelcast.map.impl.DefaultRecordStore.put(DefaultRecordStore.java:717)

at com.hazelcast.map.impl.operation.PutOperation.run(PutOperation.java:33)

at com.hazelcast.spi.impl.BasicOperationService$OperationHandler.handle(BasicOperationService.java:733)

at com.hazelcast.spi.impl.BasicOperationService$OperationHandler.access$500(BasicOperationService.java:709)

at com.hazelcast.spi.impl.BasicOperationService$OperationPacketHandler.handle(BasicOperationService.java:683)

at com.hazelcast.spi.impl.BasicOperationService$OperationPacketHandler.handle(BasicOperationService.java:627)

at com.hazelcast.spi.impl.BasicOperationService$OperationPacketHandler.access$1500(BasicOperationService.java:614)

at com.hazelcast.spi.impl.BasicOperationService$BasicDispatcherImpl.dispatch(BasicOperationService.java:566)

at com.hazelcast.spi.impl.BasicOperationScheduler$OperationThread.process(BasicOperationScheduler.java:466)

at com.hazelcast.spi.impl.BasicOperationScheduler$OperationThread.doRun(BasicOperationScheduler.java:458)

at com.hazelcast.spi.impl.BasicOperationScheduler$OperationThread.run(BasicOperationScheduler.java:432)

at ------ End remote and begin local stack-trace ------.(Unknown Source)

at com.hazelcast.spi.impl.BasicInvocationFuture.resolveApplicationResponse(BasicInvocationFuture.java:387)

at com.hazelcast.spi.impl.BasicInvocationFuture.resolveApplicationResponseOrThrowException(BasicInvocationFuture.java:320)

at com.hazelcast.spi.impl.BasicInvocationFuture.get(BasicInvocationFuture.java:194)

at com.hazelcast.spi.impl.BasicInvocationFuture.get(BasicInvocationFuture.java:173)

at com.hazelcast.map.impl.proxy.MapProxySupport.invokeOperation(MapProxySupport.java:404)

at com.hazelcast.map.impl.proxy.MapProxySupport.putInternal(MapProxySupport.java:365)

at com.hazelcast.map.impl.proxy.MapProxyImpl.put(MapProxyImpl.java:102)

at com.hazelcast.map.impl.proxy.MapProxyImpl.put(MapProxyImpl.java:89)

at IndexDemo2.main(IndexDemo2.java:20)

Caused by: java.lang.ClassNotFoundException: MyObj

at java.net.URLClassLoader$1.run(URLClassLoader.java:202)

at java.security.AccessController.doPrivileged(Native Method)

at java.net.URLClassLoader.findClass(URLClassLoader.java:190)

at java.lang.ClassLoader.loadClass(ClassLoader.java:307)

at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)

at java.lang.ClassLoader.loadClass(ClassLoader.java:248)

at com.hazelcast.nio.ClassLoaderUtil.tryLoadClass(ClassLoaderUtil.java:124)

at com.hazelcast.nio.ClassLoaderUtil.loadClass(ClassLoaderUtil.java:113)

at com.hazelcast.nio.IOUtil$1.resolveClass(IOUtil.java:113)

at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1575)

at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1496)

at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1732)

at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1329)

at java.io.ObjectInputStream.readObject(ObjectInputStream.java:351)

at com.hazelcast.nio.serialization.DefaultSerializers$ObjectSerializer.read(DefaultSerializers.java:196)