[infinispan-issues] [JBoss JIRA] (ISPN-3976) Protobuf marshalling on Indexed server caches interferes with keySet and bulk marshalling

[Adrian Nistor (JIRA)]

    [ https://issues.jboss.org/browse/ISPN-3976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12953005#comment-12953005 ] 

Adrian Nistor commented on ISPN-3976:
-------------------------------------

It seems you need a clustered (not fully replicated) cache to reproduce this. It does not happen in any other circumstances.
Then you need to add some logging here and there in m/r code to highlight exceptions that otherwise get swallowed, and here is what you get:
{code}
Caused by: java.lang.ClassCastException: org.infinispan.query.remote.indexing.ProtobufValueWrapper cannot be cast to [B
	at org.infinispan.server.hotrod.util.BulkUtil$KeyMapper.map(BulkUtil.java:40) [infinispan.jar:7.0.0-SNAPSHOT]
	at org.infinispan.distexec.mapreduce.MapReduceManagerImpl$2.apply(MapReduceManagerImpl.java:197) [infinispan-core.jar:7.0.0-SNAPSHOT]
	at org.infinispan.distexec.mapreduce.MapReduceManagerImpl$2.apply(MapReduceManagerImpl.java:192) [infinispan-core.jar:7.0.0-SNAPSHOT]
	at org.infinispan.container.DefaultDataContainer$1.apply(DefaultDataContainer.java:381) [infinispan-core.jar:7.0.0-SNAPSHOT]
	at org.infinispan.container.DefaultDataContainer$1.apply(DefaultDataContainer.java:377) [infinispan-core.jar:7.0.0-SNAPSHOT]
	at org.infinispan.commons.util.concurrent.jdk8backported.ConcurrentParallelHashMapV8$1.apply(ConcurrentParallelHashMapV8.java:48) [infinispan-commons.jar:7.0.0-SNAPSHOT]
	at org.infinispan.commons.util.concurrent.jdk8backported.EquivalentConcurrentHashMapV8$ForEachMappingTask.compute(EquivalentConcurrentHashMapV8.java:4891) [infinispan-commons.jar:7.0.0-SNAPSHOT]
	at org.infinispan.commons.util.concurrent.jdk8backported.CountedCompleter.exec(CountedCompleter.java:681) [infinispan-commons.jar:7.0.0-SNAPSHOT]
	at org.infinispan.commons.util.concurrent.jdk8backported.ForkJoinTask.doExec(ForkJoinTask.java:264) [infinispan-commons.jar:7.0.0-SNAPSHOT]
	at org.infinispan.commons.util.concurrent.jdk8backported.ForkJoinTask.doInvoke(ForkJoinTask.java:360) [infinispan-commons.jar:7.0.0-SNAPSHOT]
	at org.infinispan.commons.util.concurrent.jdk8backported.ForkJoinTask.invoke(ForkJoinTask.java:692) [infinispan-commons.jar:7.0.0-SNAPSHOT]
	at org.infinispan.commons.util.concurrent.jdk8backported.EquivalentConcurrentHashMapV8.forEach(EquivalentConcurrentHashMapV8.java:3589) [infinispan-commons.jar:7.0.0-SNAPSHOT]
	at org.infinispan.commons.util.concurrent.jdk8backported.ConcurrentParallelHashMapV8.forEach(ConcurrentParallelHashMapV8.java:44) [infinispan-commons.jar:7.0.0-SNAPSHOT]
	at org.infinispan.container.DefaultDataContainer.executeTask(DefaultDataContainer.java:377) [infinispan-core.jar:7.0.0-SNAPSHOT]
	at org.infinispan.distexec.mapreduce.MapReduceManagerImpl.map(MapReduceManagerImpl.java:192) [infinispan-core.jar:7.0.0-SNAPSHOT]
	at org.infinispan.distexec.mapreduce.MapReduceManagerImpl.mapAndCombineForLocalReduction(MapReduceManagerImpl.java:91) [infinispan-core.jar:7.0.0-SNAPSHOT]
	at org.infinispan.distexec.mapreduce.MapReduceTask$MapTaskPart.invokeMapCombineLocallyForLocalReduction(MapReduceTask.java:1008) [infinispan-core.jar:7.0.0-SNAPSHOT]
	at org.infinispan.distexec.mapreduce.MapReduceTask$MapTaskPart.access$300(MapReduceTask.java:947) [infinispan-core.jar:7.0.0-SNAPSHOT]
	at org.infinispan.distexec.mapreduce.MapReduceTask$MapTaskPart$2.call(MapReduceTask.java:979) [infinispan-core.jar:7.0.0-SNAPSHOT]
	at org.infinispan.distexec.mapreduce.MapReduceTask$MapTaskPart$2.call(MapReduceTask.java:975) [infinispan-core.jar:7.0.0-SNAPSHOT]
	at java.util.concurrent.FutureTask.run(FutureTask.java:262) [rt.jar:1.7.0_40]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) [rt.jar:1.7.0_40]
	at java.util.concurrent.FutureTask.run(FutureTask.java:262) [rt.jar:1.7.0_40]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) [rt.jar:1.7.0_40]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) [rt.jar:1.7.0_40]
	at java.lang.Thread.run(Thread.java:724) [rt.jar:1.7.0_40]
	at org.jboss.threads.JBossThread.run(JBossThread.java:122)
{code}

Finally.
                
> Protobuf marshalling on Indexed server caches interferes with keySet and bulk marshalling
> -----------------------------------------------------------------------------------------
>
>                 Key: ISPN-3976
>                 URL: https://issues.jboss.org/browse/ISPN-3976
>             Project: Infinispan
>          Issue Type: Bug
>          Components: Remote Querying
>    Affects Versions: 6.0.1.Final
>            Reporter: Tristan Tarrant
>            Assignee: Adrian Nistor
>              Labels: 630
>             Fix For: 7.0.0.Final
>
>


--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira