[JBoss JIRA] (ISPN-10286) Segmented Store can get stuck with bulk write
by Ryan Emerson (Jira)
[ https://issues.jboss.org/browse/ISPN-10286?page=com.atlassian.jira.plugin... ]
Ryan Emerson updated ISPN-10286:
--------------------------------
Fix Version/s: 10.0.0.CR2
> Segmented Store can get stuck with bulk write
> ---------------------------------------------
>
> Key: ISPN-10286
> URL: https://issues.jboss.org/browse/ISPN-10286
> Project: Infinispan
> Issue Type: Bug
> Components: Loaders and Stores
> Affects Versions: 10.0.0.Alpha3
> Reporter: Will Burns
> Assignee: Will Burns
> Priority: Major
> Fix For: 10.0.0.Beta4, 10.0.0.CR2
>
>
> The code was refactored in ComposedSegmentedLoadWriteStore to be more non blocking friendly. Unfortunately due to how groupBy and flatMap interact it is possible for the bulkUpdate to never complete.
> FlatMap by default sets a parallelism level of 128. this means it will request 128 groups from groupBy, but unfortunately if there are more than 128 groups, it will never complete as groupBy must publish all groups before a single one can complete. Thus any time we use flatMap after a groupBy we must either set the parallelism level to Integer.MAX_VALUE or to an explicit value if we know how many groups at max there will be.
--
This message was sent by Atlassian Jira
(v7.13.5#713005)
6 years
[JBoss JIRA] (ISPN-10286) Segmented Store can get stuck with bulk write
by Ryan Emerson (Jira)
[ https://issues.jboss.org/browse/ISPN-10286?page=com.atlassian.jira.plugin... ]
Ryan Emerson reopened ISPN-10286:
---------------------------------
> Segmented Store can get stuck with bulk write
> ---------------------------------------------
>
> Key: ISPN-10286
> URL: https://issues.jboss.org/browse/ISPN-10286
> Project: Infinispan
> Issue Type: Bug
> Components: Loaders and Stores
> Affects Versions: 10.0.0.Alpha3
> Reporter: Will Burns
> Assignee: Will Burns
> Priority: Major
> Fix For: 10.0.0.Beta4, 10.0.0.CR2
>
>
> The code was refactored in ComposedSegmentedLoadWriteStore to be more non blocking friendly. Unfortunately due to how groupBy and flatMap interact it is possible for the bulkUpdate to never complete.
> FlatMap by default sets a parallelism level of 128. this means it will request 128 groups from groupBy, but unfortunately if there are more than 128 groups, it will never complete as groupBy must publish all groups before a single one can complete. Thus any time we use flatMap after a groupBy we must either set the parallelism level to Integer.MAX_VALUE or to an explicit value if we know how many groups at max there will be.
--
This message was sent by Atlassian Jira
(v7.13.5#713005)
6 years
[JBoss JIRA] (ISPN-10580) Cluster resource
by Gustavo Fernandes (Jira)
Gustavo Fernandes created ISPN-10580:
----------------------------------------
Summary: Cluster resource
Key: ISPN-10580
URL: https://issues.jboss.org/browse/ISPN-10580
Project: Infinispan
Issue Type: Bug
Components: REST
Reporter: Gustavo Fernandes
Assignee: Gustavo Fernandes
A resource to expose cluster-wide info and operations:
* Shutdown the whole cluster
* Health of all cache managers from the server
* List of nodes
--
This message was sent by Atlassian Jira
(v7.13.5#713005)
6 years
[JBoss JIRA] (ISPN-10578) ScatteredCache RemoteMetadata should be handled by the PersistenceMarshaller
by Ryan Emerson (Jira)
[ https://issues.jboss.org/browse/ISPN-10578?page=com.atlassian.jira.plugin... ]
Ryan Emerson updated ISPN-10578:
--------------------------------
Status: Pull Request Sent (was: Open)
Git Pull Request: https://github.com/infinispan/infinispan/pull/7264
> ScatteredCache RemoteMetadata should be handled by the PersistenceMarshaller
> ----------------------------------------------------------------------------
>
> Key: ISPN-10578
> URL: https://issues.jboss.org/browse/ISPN-10578
> Project: Infinispan
> Issue Type: Bug
> Components: Core
> Affects Versions: 10.0.0.CR1
> Reporter: Ryan Emerson
> Assignee: Ryan Emerson
> Priority: Major
> Fix For: 10.0.0.CR2
>
>
> When running {{SharedStoreTest#testUnnecessaryWrites}} a {{NotSerializableException}} is being thrown because `RemoteMetadata` is not marshallable by the persistence marshaller. This does not cause any tests to fail, however it appears in the log files for every test run.
> {code:java}
> 00:46:16,116 WARN (remote-thread-Test-NodeC-p19-t2) [PersistenceMarshallerImpl] Cannot marshall org.infinispan.container.entries.RemoteMetadata
> org.infinispan.commons.marshall.MarshallingException: java.io.NotSerializableException: org.infinispan.container.entries.RemoteMetadata
> at org.infinispan.marshall.persistence.impl.PersistenceMarshallerImpl.marshallUserObject(PersistenceMarshallerImpl.java:220) ~[classes/:?]
> at org.infinispan.marshall.persistence.impl.PersistenceMarshallerImpl.wrapUserObject(PersistenceMarshallerImpl.java:251) ~[classes/:?]
> at org.infinispan.marshall.persistence.impl.PersistenceMarshallerImpl.objectToBuffer(PersistenceMarshallerImpl.java:159) ~[classes/:?]
> at org.infinispan.marshall.persistence.impl.PersistenceMarshallerImpl.objectToBuffer(PersistenceMarshallerImpl.java:136) ~[classes/:?]
> at org.infinispan.marshall.persistence.impl.MarshallableEntryImpl.marshall(MarshallableEntryImpl.java:209) ~[classes/:?]
> at org.infinispan.marshall.persistence.impl.MarshallableEntryImpl.<init>(MarshallableEntryImpl.java:38) ~[classes/:?]
> at org.infinispan.marshall.persistence.impl.MarshalledEntryFactoryImpl.create(MarshalledEntryFactoryImpl.java:64) ~[classes/:?]
> at org.infinispan.interceptors.impl.CacheWriterInterceptor.marshalledEntry(CacheWriterInterceptor.java:525) ~[classes/:?]
> at org.infinispan.interceptors.impl.CacheWriterInterceptor.storeEntry(CacheWriterInterceptor.java:505) ~[classes/:?]
> at org.infinispan.interceptors.impl.CacheWriterInterceptor.storeEntry(CacheWriterInterceptor.java:498) ~[classes/:?]
> at org.infinispan.interceptors.impl.ScatteredCacheWriterInterceptor.storeAndUpdateStats(ScatteredCacheWriterInterceptor.java:166) ~[classes/:?]
> at org.infinispan.interceptors.impl.ScatteredCacheWriterInterceptor.lambda$handleDataWriteReturn$1(ScatteredCacheWriterInterceptor.java:154) ~[classes/:?]
> at org.infinispan.persistence.manager.OrderedUpdatesManagerImpl.checkLockAndStore(OrderedUpdatesManagerImpl.java:84) ~[classes/:?]
> at org.infinispan.interceptors.impl.ScatteredCacheWriterInterceptor.handleDataWriteReturn(ScatteredCacheWriterInterceptor.java:152) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextThenApply(BaseAsyncInterceptor.java:86) ~[classes/:?]
> at org.infinispan.interceptors.impl.ScatteredCacheWriterInterceptor.visitPutKeyValueCommand(ScatteredCacheWriterInterceptor.java:171) ~[classes/:?]
> at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:61) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:59) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.asyncInvokeNext(BaseAsyncInterceptor.java:232) ~[classes/:?]
> at org.infinispan.interceptors.impl.CacheLoaderInterceptor.visitDataCommand(CacheLoaderInterceptor.java:224) ~[classes/:?]
> at org.infinispan.interceptors.impl.CacheLoaderInterceptor.visitPutKeyValueCommand(CacheLoaderInterceptor.java:144) ~[classes/:?]
> at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:61) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextAndHandle(BaseAsyncInterceptor.java:188) ~[classes/:?]
> at org.infinispan.interceptors.impl.BiasedEntryWrappingInterceptor.setSkipRemoteGetsAndInvokeNextForDataCommand(BiasedEntryWrappingInterceptor.java:38) ~[classes/:?]
> at org.infinispan.interceptors.impl.EntryWrappingInterceptor.visitPutKeyValueCommand(EntryWrappingInterceptor.java:318) ~[classes/:?]
> at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:61) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:59) ~[classes/:?]
> at org.infinispan.interceptors.impl.PrefetchInterceptor.handleWriteCommand(PrefetchInterceptor.java:370) ~[classes/:?]
> at org.infinispan.interceptors.impl.PrefetchInterceptor.visitPutKeyValueCommand(PrefetchInterceptor.java:387) ~[classes/:?]
> at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:61) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextAndHandle(BaseAsyncInterceptor.java:188) ~[classes/:?]
> at org.infinispan.statetransfer.StateTransferInterceptor.handleNonTxWriteCommand(StateTransferInterceptor.java:309) ~[classes/:?]
> at org.infinispan.statetransfer.StateTransferInterceptor.handleWriteCommand(StateTransferInterceptor.java:252) ~[classes/:?]
> at org.infinispan.statetransfer.StateTransferInterceptor.visitPutKeyValueCommand(StateTransferInterceptor.java:96) ~[classes/:?]
> at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:61) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:59) ~[classes/:?]
> at org.infinispan.interceptors.impl.CacheMgmtInterceptor.updateStoreStatistics(CacheMgmtInterceptor.java:212) ~[classes/:?]
> at org.infinispan.interceptors.impl.CacheMgmtInterceptor.visitPutKeyValueCommand(CacheMgmtInterceptor.java:177) ~[classes/:?]
> at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:61) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:59) ~[classes/:?]
> at org.infinispan.interceptors.DDAsyncInterceptor.handleDefault(DDAsyncInterceptor.java:53) ~[classes/:?]
> at org.infinispan.interceptors.DDAsyncInterceptor.visitPutKeyValueCommand(DDAsyncInterceptor.java:59) ~[classes/:?]
> at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:61) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextAndExceptionally(BaseAsyncInterceptor.java:128) ~[classes/:?]
> at org.infinispan.interceptors.impl.InvocationContextInterceptor.visitCommand(InvocationContextInterceptor.java:89) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:61) ~[classes/:?]
> at org.infinispan.interceptors.DDAsyncInterceptor.handleDefault(DDAsyncInterceptor.java:53) ~[classes/:?]
> at org.infinispan.interceptors.DDAsyncInterceptor.visitPutKeyValueCommand(DDAsyncInterceptor.java:59) ~[classes/:?]
> at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:61) ~[classes/:?]
> at org.infinispan.interceptors.DDAsyncInterceptor.visitCommand(DDAsyncInterceptor.java:49) ~[classes/:?]
> at org.infinispan.interceptors.impl.AsyncInterceptorChainImpl.invoke(AsyncInterceptorChainImpl.java:244) ~[classes/:?]
> at org.infinispan.statetransfer.StateConsumerImpl.doApplyState(StateConsumerImpl.java:666) ~[classes/:?]
> at org.infinispan.statetransfer.StateConsumerImpl.applyChunk(StateConsumerImpl.java:632) ~[classes/:?]
> at org.infinispan.statetransfer.StateConsumerImpl.lambda$applyState$1(StateConsumerImpl.java:588) ~[classes/:?]
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
> at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:264) [?:?]
> at java.util.concurrent.FutureTask.run(FutureTask.java) [?:?]
> at org.infinispan.commons.util.concurrent.CallerRunsRejectOnShutdownPolicy.rejectedExecution(CallerRunsRejectOnShutdownPolicy.java:19) [classes/:?]
> at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:825) [?:?]
> at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1355) [?:?]
> at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:118) [?:?]
> at org.infinispan.executors.LazyInitializingExecutorService.submit(LazyInitializingExecutorService.java:108) [classes/:?]
> at org.infinispan.statetransfer.StateConsumerImpl.applyState(StateConsumerImpl.java:586) [classes/:?]
> at org.infinispan.statetransfer.StateResponseCommand.invokeAsync(StateResponseCommand.java:92) [classes/:?]
> at org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler.invokeCommand(BasePerCacheInboundInvocationHandler.java:118) [classes/:?]
> at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.invoke(BaseBlockingRunnable.java:100) [classes/:?]
> at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.runAsync(BaseBlockingRunnable.java:72) [classes/:?]
> at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.run(BaseBlockingRunnable.java:41) [classes/:?]
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
> at java.lang.Thread.run(Thread.java:834) [?:?]
> Caused by: java.io.NotSerializableException: org.infinispan.container.entries.RemoteMetadata
> at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1185) ~[?:?]
> at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:349) ~[?:?]
> at org.infinispan.commons.marshall.JavaSerializationMarshaller.objectToBuffer(JavaSerializationMarshaller.java:39) ~[classes/:?]
> at org.infinispan.commons.marshall.AbstractMarshaller.objectToByteBuffer(AbstractMarshaller.java:70) ~[classes/:?]
> at org.infinispan.commons.marshall.AbstractMarshaller.objectToByteBuffer(AbstractMarshaller.java:60) ~[classes/:?]
> at org.infinispan.marshall.persistence.impl.PersistenceMarshallerImpl.marshallUserObject(PersistenceMarshallerImpl.java:215) ~[classes/:?]
> ... 70 more
> {code}
--
This message was sent by Atlassian Jira
(v7.13.5#713005)
6 years
[JBoss JIRA] (ISPN-10578) ScatteredCache RemoteMetadata should be handled by the PersistenceMarshaller
by Ryan Emerson (Jira)
[ https://issues.jboss.org/browse/ISPN-10578?page=com.atlassian.jira.plugin... ]
Ryan Emerson updated ISPN-10578:
--------------------------------
Status: Open (was: New)
> ScatteredCache RemoteMetadata should be handled by the PersistenceMarshaller
> ----------------------------------------------------------------------------
>
> Key: ISPN-10578
> URL: https://issues.jboss.org/browse/ISPN-10578
> Project: Infinispan
> Issue Type: Bug
> Components: Core
> Affects Versions: 10.0.0.CR1
> Reporter: Ryan Emerson
> Assignee: Ryan Emerson
> Priority: Major
> Fix For: 10.0.0.CR2
>
>
> When running {{SharedStoreTest#testUnnecessaryWrites}} a {{NotSerializableException}} is being thrown because `RemoteMetadata` is not marshallable by the persistence marshaller. This does not cause any tests to fail, however it appears in the log files for every test run.
> {code:java}
> 00:46:16,116 WARN (remote-thread-Test-NodeC-p19-t2) [PersistenceMarshallerImpl] Cannot marshall org.infinispan.container.entries.RemoteMetadata
> org.infinispan.commons.marshall.MarshallingException: java.io.NotSerializableException: org.infinispan.container.entries.RemoteMetadata
> at org.infinispan.marshall.persistence.impl.PersistenceMarshallerImpl.marshallUserObject(PersistenceMarshallerImpl.java:220) ~[classes/:?]
> at org.infinispan.marshall.persistence.impl.PersistenceMarshallerImpl.wrapUserObject(PersistenceMarshallerImpl.java:251) ~[classes/:?]
> at org.infinispan.marshall.persistence.impl.PersistenceMarshallerImpl.objectToBuffer(PersistenceMarshallerImpl.java:159) ~[classes/:?]
> at org.infinispan.marshall.persistence.impl.PersistenceMarshallerImpl.objectToBuffer(PersistenceMarshallerImpl.java:136) ~[classes/:?]
> at org.infinispan.marshall.persistence.impl.MarshallableEntryImpl.marshall(MarshallableEntryImpl.java:209) ~[classes/:?]
> at org.infinispan.marshall.persistence.impl.MarshallableEntryImpl.<init>(MarshallableEntryImpl.java:38) ~[classes/:?]
> at org.infinispan.marshall.persistence.impl.MarshalledEntryFactoryImpl.create(MarshalledEntryFactoryImpl.java:64) ~[classes/:?]
> at org.infinispan.interceptors.impl.CacheWriterInterceptor.marshalledEntry(CacheWriterInterceptor.java:525) ~[classes/:?]
> at org.infinispan.interceptors.impl.CacheWriterInterceptor.storeEntry(CacheWriterInterceptor.java:505) ~[classes/:?]
> at org.infinispan.interceptors.impl.CacheWriterInterceptor.storeEntry(CacheWriterInterceptor.java:498) ~[classes/:?]
> at org.infinispan.interceptors.impl.ScatteredCacheWriterInterceptor.storeAndUpdateStats(ScatteredCacheWriterInterceptor.java:166) ~[classes/:?]
> at org.infinispan.interceptors.impl.ScatteredCacheWriterInterceptor.lambda$handleDataWriteReturn$1(ScatteredCacheWriterInterceptor.java:154) ~[classes/:?]
> at org.infinispan.persistence.manager.OrderedUpdatesManagerImpl.checkLockAndStore(OrderedUpdatesManagerImpl.java:84) ~[classes/:?]
> at org.infinispan.interceptors.impl.ScatteredCacheWriterInterceptor.handleDataWriteReturn(ScatteredCacheWriterInterceptor.java:152) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextThenApply(BaseAsyncInterceptor.java:86) ~[classes/:?]
> at org.infinispan.interceptors.impl.ScatteredCacheWriterInterceptor.visitPutKeyValueCommand(ScatteredCacheWriterInterceptor.java:171) ~[classes/:?]
> at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:61) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:59) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.asyncInvokeNext(BaseAsyncInterceptor.java:232) ~[classes/:?]
> at org.infinispan.interceptors.impl.CacheLoaderInterceptor.visitDataCommand(CacheLoaderInterceptor.java:224) ~[classes/:?]
> at org.infinispan.interceptors.impl.CacheLoaderInterceptor.visitPutKeyValueCommand(CacheLoaderInterceptor.java:144) ~[classes/:?]
> at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:61) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextAndHandle(BaseAsyncInterceptor.java:188) ~[classes/:?]
> at org.infinispan.interceptors.impl.BiasedEntryWrappingInterceptor.setSkipRemoteGetsAndInvokeNextForDataCommand(BiasedEntryWrappingInterceptor.java:38) ~[classes/:?]
> at org.infinispan.interceptors.impl.EntryWrappingInterceptor.visitPutKeyValueCommand(EntryWrappingInterceptor.java:318) ~[classes/:?]
> at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:61) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:59) ~[classes/:?]
> at org.infinispan.interceptors.impl.PrefetchInterceptor.handleWriteCommand(PrefetchInterceptor.java:370) ~[classes/:?]
> at org.infinispan.interceptors.impl.PrefetchInterceptor.visitPutKeyValueCommand(PrefetchInterceptor.java:387) ~[classes/:?]
> at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:61) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextAndHandle(BaseAsyncInterceptor.java:188) ~[classes/:?]
> at org.infinispan.statetransfer.StateTransferInterceptor.handleNonTxWriteCommand(StateTransferInterceptor.java:309) ~[classes/:?]
> at org.infinispan.statetransfer.StateTransferInterceptor.handleWriteCommand(StateTransferInterceptor.java:252) ~[classes/:?]
> at org.infinispan.statetransfer.StateTransferInterceptor.visitPutKeyValueCommand(StateTransferInterceptor.java:96) ~[classes/:?]
> at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:61) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:59) ~[classes/:?]
> at org.infinispan.interceptors.impl.CacheMgmtInterceptor.updateStoreStatistics(CacheMgmtInterceptor.java:212) ~[classes/:?]
> at org.infinispan.interceptors.impl.CacheMgmtInterceptor.visitPutKeyValueCommand(CacheMgmtInterceptor.java:177) ~[classes/:?]
> at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:61) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:59) ~[classes/:?]
> at org.infinispan.interceptors.DDAsyncInterceptor.handleDefault(DDAsyncInterceptor.java:53) ~[classes/:?]
> at org.infinispan.interceptors.DDAsyncInterceptor.visitPutKeyValueCommand(DDAsyncInterceptor.java:59) ~[classes/:?]
> at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:61) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextAndExceptionally(BaseAsyncInterceptor.java:128) ~[classes/:?]
> at org.infinispan.interceptors.impl.InvocationContextInterceptor.visitCommand(InvocationContextInterceptor.java:89) ~[classes/:?]
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:61) ~[classes/:?]
> at org.infinispan.interceptors.DDAsyncInterceptor.handleDefault(DDAsyncInterceptor.java:53) ~[classes/:?]
> at org.infinispan.interceptors.DDAsyncInterceptor.visitPutKeyValueCommand(DDAsyncInterceptor.java:59) ~[classes/:?]
> at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:61) ~[classes/:?]
> at org.infinispan.interceptors.DDAsyncInterceptor.visitCommand(DDAsyncInterceptor.java:49) ~[classes/:?]
> at org.infinispan.interceptors.impl.AsyncInterceptorChainImpl.invoke(AsyncInterceptorChainImpl.java:244) ~[classes/:?]
> at org.infinispan.statetransfer.StateConsumerImpl.doApplyState(StateConsumerImpl.java:666) ~[classes/:?]
> at org.infinispan.statetransfer.StateConsumerImpl.applyChunk(StateConsumerImpl.java:632) ~[classes/:?]
> at org.infinispan.statetransfer.StateConsumerImpl.lambda$applyState$1(StateConsumerImpl.java:588) ~[classes/:?]
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
> at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:264) [?:?]
> at java.util.concurrent.FutureTask.run(FutureTask.java) [?:?]
> at org.infinispan.commons.util.concurrent.CallerRunsRejectOnShutdownPolicy.rejectedExecution(CallerRunsRejectOnShutdownPolicy.java:19) [classes/:?]
> at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:825) [?:?]
> at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1355) [?:?]
> at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:118) [?:?]
> at org.infinispan.executors.LazyInitializingExecutorService.submit(LazyInitializingExecutorService.java:108) [classes/:?]
> at org.infinispan.statetransfer.StateConsumerImpl.applyState(StateConsumerImpl.java:586) [classes/:?]
> at org.infinispan.statetransfer.StateResponseCommand.invokeAsync(StateResponseCommand.java:92) [classes/:?]
> at org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler.invokeCommand(BasePerCacheInboundInvocationHandler.java:118) [classes/:?]
> at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.invoke(BaseBlockingRunnable.java:100) [classes/:?]
> at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.runAsync(BaseBlockingRunnable.java:72) [classes/:?]
> at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.run(BaseBlockingRunnable.java:41) [classes/:?]
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
> at java.lang.Thread.run(Thread.java:834) [?:?]
> Caused by: java.io.NotSerializableException: org.infinispan.container.entries.RemoteMetadata
> at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1185) ~[?:?]
> at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:349) ~[?:?]
> at org.infinispan.commons.marshall.JavaSerializationMarshaller.objectToBuffer(JavaSerializationMarshaller.java:39) ~[classes/:?]
> at org.infinispan.commons.marshall.AbstractMarshaller.objectToByteBuffer(AbstractMarshaller.java:70) ~[classes/:?]
> at org.infinispan.commons.marshall.AbstractMarshaller.objectToByteBuffer(AbstractMarshaller.java:60) ~[classes/:?]
> at org.infinispan.marshall.persistence.impl.PersistenceMarshallerImpl.marshallUserObject(PersistenceMarshallerImpl.java:215) ~[classes/:?]
> ... 70 more
> {code}
--
This message was sent by Atlassian Jira
(v7.13.5#713005)
6 years