[infinispan-issues] [JBoss JIRA] (ISPN-3468) ClassCastException in map-reduce with unfamiliar key type, some cache stores and storeAsBinary

[Krzysztof Sobolewski (JIRA)]

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

Krzysztof Sobolewski commented on ISPN-3468:
--------------------------------------------

Oh, the test case is in a base test class so it will be run for all cache stores that include a test class extending this one. It should fail for JdbcBinaryCacheStore at least.
                
> ClassCastException in map-reduce with unfamiliar key type, some cache stores and storeAsBinary
> ----------------------------------------------------------------------------------------------
>
>                 Key: ISPN-3468
>                 URL: https://issues.jboss.org/browse/ISPN-3468
>             Project: Infinispan
>          Issue Type: Bug
>          Components: Loaders and Stores
>    Affects Versions: 5.3.0.Final
>            Reporter: Krzysztof Sobolewski
>            Assignee: Mircea Markus
>         Attachments: 0001-core-add-BaseCacheStoreFunctionalTest.testMapReduceS.patch
>
>
> The conditions needed to replicate:
> 1) storeAsBinary enabled for keys
> 2) a cache store that marshals keys directly, e.g. any BucketBasedCacheStore (I'm using JdbcBinaryCacheStore)
> 3) a key type that is unfamiliar to MarshalledValue.isTypeExcluded(Class<?>)
> If these are satisfied, then map-reduce fails with an exception like this:
> org.infinispan.CacheException: java.util.concurrent.ExecutionException: java.lang.ClassCastException: org.infinispan.marshall.MarshalledValue cannot be cast to com.example.UnfamiliarKeyType
>         at com.example.TestMapper.map(TestMapper.java:11) ~[?:?]
>         at org.infinispan.distexec.mapreduce.MapReduceManagerImpl.map(MapReduceManagerImpl.java:216) ~[?:?]
>         at org.infinispan.distexec.mapreduce.MapReduceManagerImpl.mapAndCombineForLocalReduction(MapReduceManagerImpl.java:103) ~[?:?]
>         at org.infinispan.distexec.mapreduce.MapReduceTask$MapTaskPart.invokeMapCombineLocallyForLocalReduction(MapReduceTask.java:977) ~[?:?]
>         at org.infinispan.distexec.mapreduce.MapReduceTask$MapTaskPart.access$300(MapReduceTask.java:916) ~[?:?]
>         at org.infinispan.distexec.mapreduce.MapReduceTask$MapTaskPart$2.call(MapReduceTask.java:948) ~[?:?]
>         at org.infinispan.distexec.mapreduce.MapReduceTask$MapTaskPart$2.call(MapReduceTask.java:944) ~[?:?]
>         at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) ~[?:1.6.0_45]
>         at java.util.concurrent.FutureTask.run(FutureTask.java:138) ~[?:1.6.0_45]
>         at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439) ~[?:1.6.0_45]
>         at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) ~[?:1.6.0_45]
>         at java.util.concurrent.FutureTask.run(FutureTask.java:138) ~[?:1.6.0_45]
>         at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895) ~[?:1.6.0_45]
>         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) ~[?:1.6.0_45]

--
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