Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

PartitionPredicate on MapAggregation throws exception when called from client #11923

Closed
gokhanoner opened this issue Dec 6, 2017 · 0 comments
Closed

Comments

@gokhanoner
Copy link
Contributor

@gokhanoner gokhanoner commented Dec 6, 2017

Predicate partitionPredicate = new PartitionPredicate<Integer, Integer>(1, Predicates.between("this", 1, 5)); Long aggregate = mapC.aggregate(Aggregators.<Map.Entry<Integer, Integer>>integerSum(), partitionPredicate);

Above predicate causes below exception when called from client

java.lang.ArrayIndexOutOfBoundsException: -1
    at com.hazelcast.internal.partition.impl.PartitionStateManager.getPartitionImpl(PartitionStateManager.java:294)
    at com.hazelcast.internal.partition.impl.InternalPartitionServiceImpl.getPartition(InternalPartitionServiceImpl.java:836)
    at com.hazelcast.internal.partition.impl.InternalPartitionServiceImpl.getPartition(InternalPartitionServiceImpl.java:831)
    at com.hazelcast.spi.impl.operationservice.impl.PartitionInvocation.getTarget(PartitionInvocation.java:50)
    at com.hazelcast.spi.impl.operationservice.impl.Invocation.initInvocationTarget(Invocation.java:238)
    at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvoke(Invocation.java:535)
    at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke0(Invocation.java:513)
    at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke(Invocation.java:207)
    at com.hazelcast.spi.impl.operationservice.impl.OperationServiceImpl.invokeOnPartition(OperationServiceImpl.java:310)
    at com.hazelcast.client.impl.protocol.task.map.AbstractMapQueryMessageTask.invokeOnPartition(AbstractMapQueryMessageTask.java:120)
    at com.hazelcast.client.impl.protocol.task.map.AbstractMapQueryMessageTask.call(AbstractMapQueryMessageTask.java:96)
    at com.hazelcast.client.impl.protocol.task.AbstractCallableMessageTask.processMessage(AbstractCallableMessageTask.java:35)
    at com.hazelcast.client.impl.protocol.task.AbstractMessageTask.initializeAndProcessMessage(AbstractMessageTask.java:123)
    at com.hazelcast.client.impl.protocol.task.AbstractMessageTask.run(AbstractMessageTask.java:103)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:748)
    at com.hazelcast.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:64)
    at com.hazelcast.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:80)
    at ------ submitted from ------.(Unknown Source)
    at com.hazelcast.spi.impl.operationservice.impl.InvocationFuture.resolve(InvocationFuture.java:127)
    at com.hazelcast.spi.impl.operationservice.impl.InvocationFuture.resolveAndThrowIfException(InvocationFuture.java:79)
    at com.hazelcast.spi.impl.AbstractInvocationFuture.get(AbstractInvocationFuture.java:147)
    at com.hazelcast.client.impl.protocol.task.map.AbstractMapQueryMessageTask.invokeOnPartition(AbstractMapQueryMessageTask.java:120)
    at com.hazelcast.client.impl.protocol.task.map.AbstractMapQueryMessageTask.call(AbstractMapQueryMessageTask.java:96)
    at com.hazelcast.client.impl.protocol.task.AbstractCallableMessageTask.processMessage(AbstractCallableMessageTask.java:35)
    at com.hazelcast.client.impl.protocol.task.AbstractMessageTask.initializeAndProcessMessage(AbstractMessageTask.java:123)
    at com.hazelcast.client.impl.protocol.task.AbstractMessageTask.run(AbstractMessageTask.java:103)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:748)
    at com.hazelcast.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:64)
    at com.hazelcast.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:80)
    at ------ submitted from ------.(Unknown Source)
    at com.hazelcast.client.spi.impl.ClientInvocationFuture.resolveAndThrowIfException(ClientInvocationFuture.java:96)
    at com.hazelcast.client.spi.impl.ClientInvocationFuture.resolveAndThrowIfException(ClientInvocationFuture.java:33)
    at com.hazelcast.spi.impl.AbstractInvocationFuture.get(AbstractInvocationFuture.java:155)
    at com.hazelcast.client.spi.ClientProxy.invoke(ClientProxy.java:231)
    at com.hazelcast.client.proxy.ClientMapProxy.aggregate(ClientMapProxy.java:1382)
@sancar sancar added the Type: Defect label Dec 6, 2017
@sancar sancar added this to the 3.9.2 milestone Dec 6, 2017
sancar added a commit to sancar/hazelcast that referenced this issue Dec 11, 2017
sancar added a commit to sancar/hazelcast that referenced this issue Dec 11, 2017
sancar added a commit to sancar/hazelcast that referenced this issue Dec 11, 2017
sancar added a commit to sancar/hazelcast that referenced this issue Dec 11, 2017
sancar added a commit to sancar/hazelcast that referenced this issue Dec 11, 2017
sancar added a commit to sancar/hazelcast that referenced this issue Dec 11, 2017
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Linked pull requests

Successfully merging a pull request may close this issue.

3 participants
You can’t perform that action at this time.