[infinispan-issues] [JBoss JIRA] (ISPN-4583) Distributed iterator throws ClassCastException when loader contains values that pass filter

[William Burns (JIRA)]

     [ https://issues.jboss.org/browse/ISPN-4583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

William Burns updated ISPN-4583:
--------------------------------

    Summary: Distributed iterator throws ClassCastException when loader contains values that pass filter  (was: Distributed iterator throws ClassCastException when LevelDB cache store contains passivated entries)


> Distributed iterator throws ClassCastException when loader contains values that pass filter
> -------------------------------------------------------------------------------------------
>
>                 Key: ISPN-4583
>                 URL: https://issues.jboss.org/browse/ISPN-4583
>             Project: Infinispan
>          Issue Type: Bug
>      Security Level: Public(Everyone can see) 
>          Components: Core
>    Affects Versions: 7.0.0.Alpha5
>            Reporter: Alan Field
>            Assignee: William Burns
>         Attachments: repl-udp-no-tx-leveldb-jni.xml
>
>
> This code will iterate over all of the entries in a cache to get the total size:
> {code:java}
>       public int getTotalSize() {
>          log.info(getClass().getName() + ".getTotalSize() for cache " + cache.getName());
>          int totalSize = 0;
>          EntryIterable entryIterator = null;
>          try {
>             entryIterator = cache.filterEntries(new AllEntriesFilter());
>             CloseableIterable ci = entryIterator.converter(new AllEntriesConverter());
>             Iterator iter = ci.iterator();
>             while (iter.hasNext()) {
>                iter.next();
>                totalSize++;
>             }
>             return totalSize;
>          } finally {
>             if (entryIterator != null) {
>                try {
>                   entryIterator.close();
>                } catch (Exception e) {
>                   log.error("Failed to close EntryIterable", e);
>                }
>             }
>          }
>       }
> {code}
> I wanted to verify that this code would also work when I was using passivation and a cachestore. The repl-udp-no-tx-leveldb-jni.xml file defines the configuration that I am using. I run a test that puts random data into the cache then checks the size of the cache, but I am getting a bunch of ClassCastException exceptions during the iteration:
> {noformat}
> java.lang.ClassCastException: java.lang.String cannot be cast to org.infinispan.container.entries.InternalCacheEntry
>         at org.infinispan.iteration.impl.LocalEntryRetriever$MapAction.apply(LocalEntryRetriever.java:251)
>         at org.infinispan.iteration.impl.LocalEntryRetriever$KeyValueActionForCacheLoaderTask.processEntry(LocalEntryRetriever.java:154)
>         at org.infinispan.persistence.leveldb.LevelDBStore$1.call(LevelDBStore.java:297)
>         at org.infinispan.persistence.leveldb.LevelDBStore$1.call(LevelDBStore.java:285)
>         at java.util.concurrent.FutureTask.run(FutureTask.java:262)
>         at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
>         at java.util.concurrent.FutureTask.run(FutureTask.java:262)
>         at org.infinispan.util.concurrent.WithinThreadExecutor.execute(WithinThreadExecutor.java:22)
>         at java.util.concurrent.ExecutorCompletionService.submit(ExecutorCompletionService.java:181)
>         at org.infinispan.executors.ExecutorAllCompletionService.submit(ExecutorAllCompletionService.java:31)
>         at org.infinispan.persistence.leveldb.LevelDBStore.submitProcessTask(LevelDBStore.java:285)
>         at org.infinispan.persistence.leveldb.LevelDBStore.process(LevelDBStore.java:260)
>         at org.infinispan.persistence.manager.PersistenceManagerImpl.processOnAllStores(PersistenceManagerImpl.java:438)
>         at org.infinispan.persistence.manager.PersistenceManagerImpl.processOnAllStores(PersistenceManagerImpl.java:420)
>         at org.infinispan.iteration.impl.LocalEntryRetriever$1.run(LocalEntryRetriever.java:217)
>         at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
>         at java.util.concurrent.FutureTask.run(FutureTask.java:262)
>         at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
>         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>         at java.lang.Thread.run(Thread.java:745)
> {noformat}



--
This message was sent by Atlassian JIRA
(v6.2.6#6264)