i have created map reduce job fetch number of employees of location. using hazelcast 3.6.3. each employee has name , address.
i have added code following git repository. https://github.com/adasari/hazelcast-demo
exception :
java.util.concurrent.executionexception: java.lang.classcastexception: com.hazelcast.mapreduce.aggregation.impl.distinctvaluesaggregation$simpleentry cannot cast com.hazelcast.query.impl.extractable @ com.hazelcast.mapreduce.impl.task.trackablejobfuture.setresult(trackablejobfuture.java:68) @ com.hazelcast.mapreduce.impl.task.jobsupervisor.notifyremoteexception(jobsupervisor.java:156) @ com.hazelcast.mapreduce.impl.operation.notifyremoteexceptionoperation.run(notifyremoteexceptionoperation.java:54) @ com.hazelcast.spi.impl.operationservice.impl.operationrunnerimpl.run(operationrunnerimpl.java:172) @ com.hazelcast.spi.impl.operationservice.impl.operationrunnerimpl.run(operationrunnerimpl.java:393) @ com.hazelcast.spi.impl.operationexecutor.classic.operationthread.processpacket(operationthread.java:184) @ com.hazelcast.spi.impl.operationexecutor.classic.operationthread.process(operationthread.java:137) @ com.hazelcast.spi.impl.operationexecutor.classic.operationthread.dorun(operationthread.java:124) @ com.hazelcast.spi.impl.operationexecutor.classic.operationthread.run(operationthread.java:99) caused by: java.lang.classcastexception: com.hazelcast.mapreduce.aggregation.impl.distinctvaluesaggregation$simpleentry cannot cast com.hazelcast.query.impl.extractable @ com.hazelcast.query.impl.predicates.abstractpredicate.readattributevalue(abstractpredicate.java:129) @ com.hazelcast.query.impl.predicates.abstractpredicate.apply(abstractpredicate.java:55)
can point me issue ?
thanks.
not sure you're looking or you're trying (looking @ code) problem here:
caused by: java.lang.classcastexception: com.hazelcast.mapreduce.aggregation.impl.distinctvaluesaggregation$simpleentry cannot cast com.hazelcast.query.impl.extractable
so have implement extractable interface simpleentry class.
Comments
Post a Comment