[Red Hat JIRA] (ISPN-12635) Multimap Bucket can't get replicated in server mode
by Pedro Ruivo (Jira)
[ https://issues.redhat.com/browse/ISPN-12635?page=com.atlassian.jira.plugi... ]
Pedro Ruivo updated ISPN-12635:
-------------------------------
Summary: Multimap Bucket can't get replicated in server mode (was: Multimap Bucket can't get replicated)
> Multimap Bucket can't get replicated in server mode
> ---------------------------------------------------
>
> Key: ISPN-12635
> URL: https://issues.redhat.com/browse/ISPN-12635
> Project: Infinispan
> Issue Type: Bug
> Components: Multimap
> Affects Versions: 12.0.0.CR1
> Reporter: Katia Aresti
> Assignee: Pedro Ruivo
> Priority: Critical
>
> To reproduce the issue
> * Launch two Xsite clusters
> * Create a cache and the backup
> * Use multimap remote api to put some values (Remote Simple tutorial)
>
> The server logs
>
> {{ispn-lon-2 | 12:24:21,750 WARN (jgroups-11,cac3675c5cbc-55154) [org.infinispan.xsite.BackupSenderImpl] ISPN000202: Problems backing up data for cache xsiteCache to site NYC: org.infinispan.commons.marshall.MarshallingException: No marshaller registered for Java type org.infinispan.commons.marshall.WrappedByteArrayispn-lon-2 | 12:24:21,750 WARN (jgroups-11,cac3675c5cbc-55154) [org.infinispan.xsite.BackupSenderImpl] ISPN000202: Problems backing up data for cache xsiteCache to site NYC: org.infinispan.commons.marshall.MarshallingException: No marshaller registered for Java type org.infinispan.commons.marshall.WrappedByteArrayispn-lon-2 | 12:24:21,756 WARN (jgroups-11,cac3675c5cbc-55154) [org.infinispan.PERSISTENCE] ISPN000559: Cannot marshall 'class org.infinispan.multimap.impl.Bucket' java.lang.IllegalArgumentException: No marshaller registered for Java type org.infinispan.commons.marshall.WrappedByteArrayispn-lon-2 | at org.infinispan.protostream.impl.SerializationContextImpl.getMarshallerDelegate(SerializationContextImpl.java:298)ispn-lon-2 | at org.infinispan.protostream.WrappedMessage.writeMessage(WrappedMessage.java:240)ispn-lon-2 | at org.infinispan.protostream.ProtobufUtil.toWrappedByteArray(ProtobufUtil.java:132)ispn-lon-2 | at org.infinispan.protostream.ProtobufUtil.toWrappedByteArray(ProtobufUtil.java:127)ispn-lon-2 | at org.infinispan.commons.marshall.ImmutableProtoStreamMarshaller.objectToBuffer(ImmutableProtoStreamMarshaller.java:55)ispn-lon-2 | at org.infinispan.commons.marshall.AbstractMarshaller.objectToByteBuffer(AbstractMarshaller.java:70)ispn-lon-2 | at org.infinispan.commons.marshall.AbstractMarshaller.objectToByteBuffer(AbstractMarshaller.java:60)ispn-lon-2 | at org.infinispan.marshall.core.impl.DelegatingUserMarshaller.objectToByteBuffer(DelegatingUserMarshaller.java:58)ispn-lon-2 | at org.infinispan.marshall.protostream.impl.MarshallableUserObject$Marshaller.writeTo(MarshallableUserObject.java:149)ispn-lon-2 | at org.infinispan.marshall.protostream.impl.MarshallableUserObject$Marshaller.writeTo(MarshallableUserObject.java:102)ispn-lon-2 | at org.infinispan.protostream.impl.RawProtobufMarshallerDelegate.marshall(RawProtobufMarshallerDelegate.java:32)ispn-lon-2 | at org.infinispan.protostream.annotations.impl.GeneratedMarshallerBase.writeMessage(GeneratedMarshallerBase.java:34)ispn-lon-2 | at org.infinispan.protostream.annotations.impl.GeneratedMarshallerBase.writeNestedMessage(GeneratedMarshallerBase.java:45)ispn-lon-2 | at org.infinispan.multimap.impl.Bucket$___Marshaller_686dc55729a31972fef7d4722c2e90e0421789a20c8a9d4176be1714ac94d28c.writeTo(Bucket$___Marshaller_686dc55729a31972fef7d4722c2e90e0421789a20c8a9d4176be1714ac94d28c.java:69)ispn-lon-2 | at org.infinispan.multimap.impl.Bucket$___Marshaller_686dc55729a31972fef7d4722c2e90e0421789a20c8a9d4176be1714ac94d28c.writeTo(Bucket$___Marshaller_686dc55729a31972fef7d4722c2e90e0421789a20c8a9d4176be1714ac94d28c.java:15)ispn-lon-2 | at org.infinispan.protostream.impl.RawProtobufMarshallerDelegate.marshall(RawProtobufMarshallerDelegate.java:32)ispn-lon-2 | at org.infinispan.protostream.WrappedMessage.writeMessage(WrappedMessage.java:257)ispn-lon-2 | at org.infinispan.protostream.ProtobufUtil.toWrappedStream(ProtobufUtil.java:147)ispn-lon-2 | at org.infinispan.marshall.protostream.impl.AbstractInternalProtoStreamMarshaller.objectToByteBuffer(AbstractInternalProtoStreamMarshaller.java:75)ispn-lon-2 | at org.infinispan.marshall.protostream.impl.AbstractInternalProtoStreamMarshaller.objectToByteBuffer(AbstractInternalProtoStreamMarshaller.java:87)ispn-lon-2 | at org.infinispan.marshall.core.GlobalMarshaller.writeRawUnknown(GlobalMarshaller.java:637)ispn-lon-2 | at org.infinispan.marshall.core.GlobalMarshaller.writeUnknown(GlobalMarshaller.java:626)ispn-lon-2 | at org.infinispan.marshall.core.GlobalMarshaller.writeUnknown(GlobalMarshaller.java:617)ispn-lon-2 | at org.infinispan.marshall.core.GlobalMarshaller.writeNonNullableObject(GlobalMarshaller.java:383)ispn-lon-2 | at org.infinispan.marshall.core.GlobalMarshaller.writeNullableObject(GlobalMarshaller.java:351)ispn-lon-2 | at org.infinispan.marshall.core.BytesObjectOutput.writeObject(BytesObjectOutput.java:26)ispn-lon-2 | at org.infinispan.commands.write.PutKeyValueCommand.writeTo(PutKeyValueCommand.java:83)ispn-lon-2 | at org.infinispan.marshall.exts.ReplicableCommandExternalizer.writeCommandParameters(ReplicableCommandExternalizer.java:83)ispn-lon-2 | at org.infinispan.marshall.exts.ReplicableCommandExternalizer.writeObject(ReplicableCommandExternalizer.java:79)ispn-lon-2 | at org.infinispan.marshall.exts.ReplicableCommandExternalizer.writeObject(ReplicableCommandExternalizer.java:67)ispn-lon-2 | at org.infinispan.marshall.core.GlobalMarshaller.writeInternal(GlobalMarshaller.java:655)ispn-lon-2 | at org.infinispan.marshall.core.GlobalMarshaller.writeNonNullableObject(GlobalMarshaller.java:370)ispn-lon-2 | at org.infinispan.marshall.core.GlobalMarshaller.writeNullableObject(GlobalMarshaller.java:351)ispn-lon-2 | at org.infinispan.marshall.core.BytesObjectOutput.writeObject(BytesObjectOutput.java:26)ispn-lon-2 | at org.infinispan.xsite.SingleXSiteRpcCommand.writeTo(SingleXSiteRpcCommand.java:66)ispn-lon-2 | at org.infinispan.marshall.exts.ReplicableCommandExternalizer.writeCommandParameters(ReplicableCommandExternalizer.java:83)ispn-lon-2 | at org.infinispan.marshall.exts.CacheRpcCommandExternalizer.marshallParameters(CacheRpcCommandExternalizer.java:144)ispn-lon-2 | at org.infinispan.marshall.exts.CacheRpcCommandExternalizer.writeObject(CacheRpcCommandExternalizer.java:140)ispn-lon-2 | at org.infinispan.marshall.exts.CacheRpcCommandExternalizer.writeObject(CacheRpcCommandExternalizer.java:82)ispn-lon-2 | at org.infinispan.marshall.core.GlobalMarshaller.writeInternal(GlobalMarshaller.java:655)ispn-lon-2 | at org.infinispan.marshall.core.GlobalMarshaller.writeNonNullableObject(GlobalMarshaller.java:370)ispn-lon-2 | at org.infinispan.marshall.core.GlobalMarshaller.writeNullableObject(GlobalMarshaller.java:351)ispn-lon-2 | at org.infinispan.marshall.core.GlobalMarshaller.writeObjectOutput(GlobalMarshaller.java:180)ispn-lon-2 | at org.infinispan.marshall.core.GlobalMarshaller.writeObjectOutput(GlobalMarshaller.java:173)ispn-lon-2 | at org.infinispan.marshall.core.GlobalMarshaller.objectToBuffer(GlobalMarshaller.java:301)ispn-lon-2 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport.marshallRequest(JGroupsTransport.java:1066)ispn-lon-2 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport.sendCommand(JGroupsTransport.java:1054)ispn-lon-2 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport.backupRemotely(JGroupsTransport.java:354)ispn-lon-2 | at org.infinispan.remoting.rpc.RpcManagerImpl.invokeXSite(RpcManagerImpl.java:376)ispn-lon-2 | at org.infinispan.xsite.BackupSenderImpl.sendTo(BackupSenderImpl.java:183)ispn-lon-2 | at org.infinispan.xsite.BackupSenderImpl.backupCommand(BackupSenderImpl.java:176)ispn-lon-2 | at org.infinispan.xsite.BackupSenderImpl.backupWrite(BackupSenderImpl.java:147)ispn-lon-2 | at org.infinispan.interceptors.xsite.NonTransactionalBackupInterceptor.handleSingleKeyWriteReturn(NonTransactionalBackupInterceptor.java:146)ispn-lon-2 | at org.infinispan.interceptors.InvocationSuccessFunction.apply(InvocationSuccessFunction.java:25)ispn-lon-2 | at org.infinispan.interceptors.impl.QueueAsyncInvocationStage.invokeQueuedHandlers(QueueAsyncInvocationStage.java:124)ispn-lon-2 | at org.infinispan.interceptors.impl.QueueAsyncInvocationStage.accept(QueueAsyncInvocationStage.java:87)ispn-lon-2 | at org.infinispan.interceptors.impl.QueueAsyncInvocationStage.accept(QueueAsyncInvocationStage.java:33)ispn-lon-2 | at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)ispn-lon-2 | at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)ispn-lon-2 | at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)ispn-lon-2 | at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)ispn-lon-2 | at org.infinispan.remoting.transport.AbstractRequest.complete(AbstractRequest.java:67)ispn-lon-2 | at org.infinispan.remoting.transport.impl.MultiTargetRequest.onResponse(MultiTargetRequest.java:105)ispn-lon-2 | at org.infinispan.remoting.transport.impl.RequestRepository.addResponse(RequestRepository.java:51)ispn-lon-2 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport.processResponse(JGroupsTransport.java:1407)ispn-lon-2 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport.processMessage(JGroupsTransport.java:1310)ispn-lon-2 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport.access$300(JGroupsTransport.java:131)ispn-lon-2 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport$ChannelCallbacks.up(JGroupsTransport.java:1450)ispn-lon-2 | at org.jgroups.JChannel.up(JChannel.java:784)ispn-lon-2 | at org.jgroups.stack.ProtocolStack.up(ProtocolStack.java:913)ispn-lon-2 | at org.jgroups.protocols.relay.RELAY2.up(RELAY2.java:499)ispn-lon-2 | at org.jgroups.protocols.FRAG3.up(FRAG3.java:165)ispn-lon-2 | at org.jgroups.protocols.FlowControl.up(FlowControl.java:343)ispn-lon-2 | at org.jgroups.protocols.FlowControl.up(FlowControl.java:343)ispn-lon-2 | at org.jgroups.protocols.pbcast.GMS.up(GMS.java:876)ispn-lon-2 | at org.jgroups.protocols.pbcast.STABLE.up(STABLE.java:243)ispn-lon-2 | at org.jgroups.protocols.UNICAST3.deliverMessage(UNICAST3.java:1049)ispn-lon-2 | at org.jgroups.protocols.UNICAST3.addMessage(UNICAST3.java:772)ispn-lon-2 | at org.jgroups.protocols.UNICAST3.handleDataReceived(UNICAST3.java:753)ispn-lon-2 | at org.jgroups.protocols.UNICAST3.up(UNICAST3.java:405)ispn-lon-2 | at org.jgroups.protocols.pbcast.NAKACK2.up(NAKACK2.java:592)ispn-lon-2 | at org.jgroups.protocols.VERIFY_SUSPECT.up(VERIFY_SUSPECT.java:132)ispn-lon-2 | at org.jgroups.protocols.FailureDetection.up(FailureDetection.java:186)ispn-lon-2 | at org.jgroups.protocols.FD_SOCK.up(FD_SOCK.java:254)ispn-lon-2 | at org.jgroups.protocols.MERGE3.up(MERGE3.java:281)ispn-lon-2 | at org.jgroups.protocols.Discovery.up(Discovery.java:300)ispn-lon-2 | at org.jgroups.protocols.TP.passMessageUp(TP.java:1396)ispn-lon-2 | at org.jgroups.util.SubmitToThreadPool$SingleMessageHandler.run(SubmitToThreadPool.java:87)ispn-lon-2 | at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)ispn-lon-2 | at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)ispn-lon-2 | at java.base/java.lang.Thread.run(Thread.java:834)ispn-lon-2 |ispn-lon-2 | 12:24:21,759 WARN (jgroups-11,cac3675c5cbc-55154) [org.infinispan.xsite.BackupSenderImpl] ISPN000202: Problems backing up data for cache xsiteCache to site NYC: org.infinispan.commons.marshall.MarshallingException: No marshaller registered for Java type org.infinispan.commons.marshall.WrappedByteArrayispn-lon-1 | 12:24:21,755 WARN (jgroups-13,9012e6269fb8-17732) [org.infinispan.PERSISTENCE] ISPN000559: Cannot marshall 'class org.infinispan.multimap.impl.Bucket' java.lang.IllegalArgumentException: No marshaller registered for Java type org.infinispan.commons.marshall.WrappedByteArrayispn-lon-1 | at org.infinispan.protostream.impl.SerializationContextImpl.getMarshallerDelegate(SerializationContextImpl.java:298)ispn-lon-1 | at org.infinispan.protostream.WrappedMessage.writeMessage(WrappedMessage.java:240)ispn-lon-1 | at org.infinispan.protostream.ProtobufUtil.toWrappedByteArray(ProtobufUtil.java:132)ispn-lon-1 | at org.infinispan.protostream.ProtobufUtil.toWrappedByteArray(ProtobufUtil.java:127)ispn-lon-1 | at org.infinispan.commons.marshall.ImmutableProtoStreamMarshaller.objectToBuffer(ImmutableProtoStreamMarshaller.java:55)ispn-lon-1 | at org.infinispan.commons.marshall.AbstractMarshaller.objectToByteBuffer(AbstractMarshaller.java:70)ispn-lon-1 | at org.infinispan.commons.marshall.AbstractMarshaller.objectToByteBuffer(AbstractMarshaller.java:60)ispn-lon-1 | at org.infinispan.marshall.core.impl.DelegatingUserMarshaller.objectToByteBuffer(DelegatingUserMarshaller.java:58)ispn-lon-1 | at org.infinispan.marshall.protostream.impl.MarshallableUserObject$Marshaller.writeTo(MarshallableUserObject.java:149)ispn-lon-1 | at org.infinispan.marshall.protostream.impl.MarshallableUserObject$Marshaller.writeTo(MarshallableUserObject.java:102)ispn-lon-1 | at org.infinispan.protostream.impl.RawProtobufMarshallerDelegate.marshall(RawProtobufMarshallerDelegate.java:32)ispn-lon-1 | at org.infinispan.protostream.annotations.impl.GeneratedMarshallerBase.writeMessage(GeneratedMarshallerBase.java:34)ispn-lon-1 | at org.infinispan.protostream.annotations.impl.GeneratedMarshallerBase.writeNestedMessage(GeneratedMarshallerBase.java:45)ispn-lon-1 | at org.infinispan.multimap.impl.Bucket$___Marshaller_686dc55729a31972fef7d4722c2e90e0421789a20c8a9d4176be1714ac94d28c.writeTo(Bucket$___Marshaller_686dc55729a31972fef7d4722c2e90e0421789a20c8a9d4176be1714ac94d28c.java:69)ispn-lon-1 | at org.infinispan.multimap.impl.Bucket$___Marshaller_686dc55729a31972fef7d4722c2e90e0421789a20c8a9d4176be1714ac94d28c.writeTo(Bucket$___Marshaller_686dc55729a31972fef7d4722c2e90e0421789a20c8a9d4176be1714ac94d28c.java:15)ispn-lon-1 | at org.infinispan.protostream.impl.RawProtobufMarshallerDelegate.marshall(RawProtobufMarshallerDelegate.java:32)ispn-lon-1 | at org.infinispan.protostream.WrappedMessage.writeMessage(WrappedMessage.java:257)ispn-lon-1 | at org.infinispan.protostream.ProtobufUtil.toWrappedStream(ProtobufUtil.java:147)ispn-lon-1 | at org.infinispan.marshall.protostream.impl.AbstractInternalProtoStreamMarshaller.objectToByteBuffer(AbstractInternalProtoStreamMarshaller.java:75)ispn-lon-1 | at org.infinispan.marshall.protostream.impl.AbstractInternalProtoStreamMarshaller.objectToByteBuffer(AbstractInternalProtoStreamMarshaller.java:87)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeRawUnknown(GlobalMarshaller.java:637)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeUnknown(GlobalMarshaller.java:626)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeUnknown(GlobalMarshaller.java:617)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeNonNullableObject(GlobalMarshaller.java:383)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeNullableObject(GlobalMarshaller.java:351)ispn-lon-1 | at org.infinispan.marshall.core.BytesObjectOutput.writeObject(BytesObjectOutput.java:26)ispn-lon-1 | at org.infinispan.commands.write.PutKeyValueCommand.writeTo(PutKeyValueCommand.java:83)ispn-lon-1 | at org.infinispan.marshall.exts.ReplicableCommandExternalizer.writeCommandParameters(ReplicableCommandExternalizer.java:83)ispn-lon-1 | at org.infinispan.marshall.exts.ReplicableCommandExternalizer.writeObject(ReplicableCommandExternalizer.java:79)ispn-lon-1 | at org.infinispan.marshall.exts.ReplicableCommandExternalizer.writeObject(ReplicableCommandExternalizer.java:67)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeInternal(GlobalMarshaller.java:655)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeNonNullableObject(GlobalMarshaller.java:370)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeNullableObject(GlobalMarshaller.java:351)ispn-lon-1 | at org.infinispan.marshall.core.BytesObjectOutput.writeObject(BytesObjectOutput.java:26)ispn-lon-1 | at org.infinispan.xsite.SingleXSiteRpcCommand.writeTo(SingleXSiteRpcCommand.java:66)ispn-lon-1 | at org.infinispan.marshall.exts.ReplicableCommandExternalizer.writeCommandParameters(ReplicableCommandExternalizer.java:83)ispn-lon-1 | at org.infinispan.marshall.exts.CacheRpcCommandExternalizer.marshallParameters(CacheRpcCommandExternalizer.java:144)ispn-lon-1 | at org.infinispan.marshall.exts.CacheRpcCommandExternalizer.writeObject(CacheRpcCommandExternalizer.java:140)ispn-lon-1 | at org.infinispan.marshall.exts.CacheRpcCommandExternalizer.writeObject(CacheRpcCommandExternalizer.java:82)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeInternal(GlobalMarshaller.java:655)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeNonNullableObject(GlobalMarshaller.java:370)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeNullableObject(GlobalMarshaller.java:351)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeObjectOutput(GlobalMarshaller.java:180)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeObjectOutput(GlobalMarshaller.java:173)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.objectToBuffer(GlobalMarshaller.java:301)ispn-lon-1 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport.marshallRequest(JGroupsTransport.java:1066)ispn-lon-1 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport.sendCommand(JGroupsTransport.java:1054)ispn-lon-1 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport.backupRemotely(JGroupsTransport.java:354)ispn-lon-1 | at org.infinispan.remoting.rpc.RpcManagerImpl.invokeXSite(RpcManagerImpl.java:376)ispn-lon-1 | at org.infinispan.xsite.BackupSenderImpl.sendTo(BackupSenderImpl.java:183)ispn-lon-1 | at org.infinispan.xsite.BackupSenderImpl.backupCommand(BackupSenderImpl.java:176)ispn-lon-1 | at org.infinispan.xsite.BackupSenderImpl.backupWrite(BackupSenderImpl.java:147)ispn-lon-1 | at org.infinispan.interceptors.xsite.NonTransactionalBackupInterceptor.handleSingleKeyWriteReturn(NonTransactionalBackupInterceptor.java:146)ispn-lon-1 | at org.infinispan.interceptors.InvocationSuccessFunction.apply(InvocationSuccessFunction.java:25)ispn-lon-1 | at org.infinispan.interceptors.impl.QueueAsyncInvocationStage.invokeQueuedHandlers(QueueAsyncInvocationStage.java:124)ispn-lon-1 | at org.infinispan.interceptors.impl.QueueAsyncInvocationStage.accept(QueueAsyncInvocationStage.java:87)ispn-lon-1 | at org.infinispan.interceptors.impl.QueueAsyncInvocationStage.accept(QueueAsyncInvocationStage.java:33)ispn-lon-1 | at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)ispn-lon-1 | at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)ispn-lon-1 | at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)ispn-lon-1 | at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)ispn-lon-1 | at org.infinispan.remoting.transport.AbstractRequest.complete(AbstractRequest.java:67)ispn-lon-1 | at org.infinispan.remoting.transport.impl.MultiTargetRequest.onResponse(MultiTargetRequest.java:105)ispn-lon-1 | at org.infinispan.remoting.transport.impl.RequestRepository.addResponse(RequestRepository.java:51)ispn-lon-1 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport.processResponse(JGroupsTransport.java:1407)ispn-lon-1 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport.processMessage(JGroupsTransport.java:1310)ispn-lon-1 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport.access$300(JGroupsTransport.java:131)ispn-lon-1 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport$ChannelCallbacks.up(JGroupsTransport.java:1450)ispn-lon-1 | at org.jgroups.JChannel.up(JChannel.java:784)ispn-lon-1 | at org.jgroups.stack.ProtocolStack.up(ProtocolStack.java:913)ispn-lon-1 | at org.jgroups.protocols.relay.RELAY2.up(RELAY2.java:499)ispn-lon-1 | at org.jgroups.protocols.FRAG3.up(FRAG3.java:165)ispn-lon-1 | at org.jgroups.protocols.FlowControl.up(FlowControl.java:343)ispn-lon-1 | at org.jgroups.protocols.FlowControl.up(FlowControl.java:343)ispn-lon-1 | at org.jgroups.protocols.pbcast.GMS.up(GMS.java:876)ispn-lon-1 | at org.jgroups.protocols.pbcast.STABLE.up(STABLE.java:243)ispn-lon-1 | at org.jgroups.protocols.UNICAST3.deliverMessage(UNICAST3.java:1049)ispn-lon-1 | at org.jgroups.protocols.UNICAST3.addMessage(UNICAST3.java:772)ispn-lon-1 | at org.jgroups.protocols.UNICAST3.handleDataReceived(UNICAST3.java:753)ispn-lon-1 | at org.jgroups.protocols.UNICAST3.up(UNICAST3.java:405)ispn-lon-1 | at org.jgroups.protocols.pbcast.NAKACK2.up(NAKACK2.java:592)ispn-lon-1 | at org.jgroups.protocols.VERIFY_SUSPECT.up(VERIFY_SUSPECT.java:132)ispn-lon-1 | at org.jgroups.protocols.FailureDetection.up(FailureDetection.java:186)ispn-lon-1 | at org.jgroups.protocols.FD_SOCK.up(FD_SOCK.java:254)ispn-lon-1 | at org.jgroups.protocols.MERGE3.up(MERGE3.java:281)ispn-lon-1 | at org.jgroups.protocols.Discovery.up(Discovery.java:300)ispn-lon-1 | at org.jgroups.protocols.TP.passMessageUp(TP.java:1396)ispn-lon-1 | at org.jgroups.util.SubmitToThreadPool$SingleMessageHandler.run(SubmitToThreadPool.java:87)ispn-lon-1 | at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)ispn-lon-1 | at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)ispn-lon-1 | at java.base/java.lang.Thread.run(Thread.java:834)ispn-lon-1 |ispn-lon-1 | 12:24:21,767 WARN (jgroups-16,9012e6269fb8-17732) [org.infinispan.PERSISTENCE] ISPN000559: Cannot marshall 'class org.infinispan.multimap.impl.Bucket' java.lang.IllegalArgumentException: No marshaller registered for Java type org.infinispan.commons.marshall.WrappedByteArrayispn-lon-1 | at org.infinispan.protostream.impl.SerializationContextImpl.getMarshallerDelegate(SerializationContextImpl.java:298)ispn-lon-1 | at org.infinispan.protostream.WrappedMessage.writeMessage(WrappedMessage.java:240)ispn-lon-1 | at org.infinispan.protostream.ProtobufUtil.toWrappedByteArray(ProtobufUtil.java:132)ispn-lon-1 | at org.infinispan.protostream.ProtobufUtil.toWrappedByteArray(ProtobufUtil.java:127)ispn-lon-1 | at org.infinispan.commons.marshall.ImmutableProtoStreamMarshaller.objectToBuffer(ImmutableProtoStreamMarshaller.java:55)ispn-lon-1 | at org.infinispan.commons.marshall.AbstractMarshaller.objectToByteBuffer(AbstractMarshaller.java:70)ispn-lon-1 | at org.infinispan.commons.marshall.AbstractMarshaller.objectToByteBuffer(AbstractMarshaller.java:60)ispn-lon-1 | at org.infinispan.marshall.core.impl.DelegatingUserMarshaller.objectToByteBuffer(DelegatingUserMarshaller.java:58)ispn-lon-1 | at org.infinispan.marshall.protostream.impl.MarshallableUserObject$Marshaller.writeTo(MarshallableUserObject.java:149)ispn-lon-1 | at org.infinispan.marshall.protostream.impl.MarshallableUserObject$Marshaller.writeTo(MarshallableUserObject.java:102)ispn-lon-1 | at org.infinispan.protostream.impl.RawProtobufMarshallerDelegate.marshall(RawProtobufMarshallerDelegate.java:32)ispn-lon-1 | at org.infinispan.protostream.annotations.impl.GeneratedMarshallerBase.writeMessage(GeneratedMarshallerBase.java:34)ispn-lon-1 | at org.infinispan.protostream.annotations.impl.GeneratedMarshallerBase.writeNestedMessage(GeneratedMarshallerBase.java:45)ispn-lon-1 | at org.infinispan.multimap.impl.Bucket$___Marshaller_686dc55729a31972fef7d4722c2e90e0421789a20c8a9d4176be1714ac94d28c.writeTo(Bucket$___Marshaller_686dc55729a31972fef7d4722c2e90e0421789a20c8a9d4176be1714ac94d28c.java:69)ispn-lon-1 | at org.infinispan.multimap.impl.Bucket$___Marshaller_686dc55729a31972fef7d4722c2e90e0421789a20c8a9d4176be1714ac94d28c.writeTo(Bucket$___Marshaller_686dc55729a31972fef7d4722c2e90e0421789a20c8a9d4176be1714ac94d28c.java:15)ispn-lon-1 | at org.infinispan.protostream.impl.RawProtobufMarshallerDelegate.marshall(RawProtobufMarshallerDelegate.java:32)ispn-lon-1 | at org.infinispan.protostream.WrappedMessage.writeMessage(WrappedMessage.java:257)ispn-lon-1 | at org.infinispan.protostream.ProtobufUtil.toWrappedStream(ProtobufUtil.java:147)ispn-lon-1 | at org.infinispan.marshall.protostream.impl.AbstractInternalProtoStreamMarshaller.objectToByteBuffer(AbstractInternalProtoStreamMarshaller.java:75)ispn-lon-1 | at org.infinispan.marshall.protostream.impl.AbstractInternalProtoStreamMarshaller.objectToByteBuffer(AbstractInternalProtoStreamMarshaller.java:87)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeRawUnknown(GlobalMarshaller.java:637)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeUnknown(GlobalMarshaller.java:626)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeUnknown(GlobalMarshaller.java:617)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeNonNullableObject(GlobalMarshaller.java:383)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeNullableObject(GlobalMarshaller.java:351)ispn-lon-1 | at org.infinispan.marshall.core.BytesObjectOutput.writeObject(BytesObjectOutput.java:26)ispn-lon-1 | at org.infinispan.commands.write.PutKeyValueCommand.writeTo(PutKeyValueCommand.java:83)ispn-lon-1 | at org.infinispan.marshall.exts.ReplicableCommandExternalizer.writeCommandParameters(ReplicableCommandExternalizer.java:83)ispn-lon-1 | at org.infinispan.marshall.exts.ReplicableCommandExternalizer.writeObject(ReplicableCommandExternalizer.java:79)ispn-lon-1 | at org.infinispan.marshall.exts.ReplicableCommandExternalizer.writeObject(ReplicableCommandExternalizer.java:67)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeInternal(GlobalMarshaller.java:655)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeNonNullableObject(GlobalMarshaller.java:370)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeNullableObject(GlobalMarshaller.java:351)ispn-lon-1 | at org.infinispan.marshall.core.BytesObjectOutput.writeObject(BytesObjectOutput.java:26)ispn-lon-1 | at org.infinispan.xsite.SingleXSiteRpcCommand.writeTo(SingleXSiteRpcCommand.java:66)ispn-lon-1 | at org.infinispan.marshall.exts.ReplicableCommandExternalizer.writeCommandParameters(ReplicableCommandExternalizer.java:83)ispn-lon-1 | at org.infinispan.marshall.exts.CacheRpcCommandExternalizer.marshallParameters(CacheRpcCommandExternalizer.java:144)ispn-lon-1 | at org.infinispan.marshall.exts.CacheRpcCommandExternalizer.writeObject(CacheRpcCommandExternalizer.java:140)ispn-lon-1 | at org.infinispan.marshall.exts.CacheRpcCommandExternalizer.writeObject(CacheRpcCommandExternalizer.java:82)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeInternal(GlobalMarshaller.java:655)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeNonNullableObject(GlobalMarshaller.java:370)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeNullableObject(GlobalMarshaller.java:351)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeObjectOutput(GlobalMarshaller.java:180)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.writeObjectOutput(GlobalMarshaller.java:173)ispn-lon-1 | at org.infinispan.marshall.core.GlobalMarshaller.objectToBuffer(GlobalMarshaller.java:301)ispn-lon-1 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport.marshallRequest(JGroupsTransport.java:1066)ispn-lon-1 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport.sendCommand(JGroupsTransport.java:1054)ispn-lon-1 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport.backupRemotely(JGroupsTransport.java:354)ispn-lon-1 | at org.infinispan.remoting.rpc.RpcManagerImpl.invokeXSite(RpcManagerImpl.java:376)ispn-lon-1 | at org.infinispan.xsite.BackupSenderImpl.sendTo(BackupSenderImpl.java:183)ispn-lon-1 | at org.infinispan.xsite.BackupSenderImpl.backupCommand(BackupSenderImpl.java:176)ispn-lon-1 | at org.infinispan.xsite.BackupSenderImpl.backupWrite(BackupSenderImpl.java:147)ispn-lon-1 | at org.infinispan.interceptors.xsite.NonTransactionalBackupInterceptor.handleSingleKeyWriteReturn(NonTransactionalBackupInterceptor.java:146)ispn-lon-1 | at org.infinispan.interceptors.InvocationSuccessFunction.apply(InvocationSuccessFunction.java:25)ispn-lon-1 | at org.infinispan.interceptors.impl.QueueAsyncInvocationStage.invokeQueuedHandlers(QueueAsyncInvocationStage.java:124)ispn-lon-1 | at org.infinispan.interceptors.impl.QueueAsyncInvocationStage.accept(QueueAsyncInvocationStage.java:87)ispn-lon-1 | at org.infinispan.interceptors.impl.QueueAsyncInvocationStage.accept(QueueAsyncInvocationStage.java:33)ispn-lon-1 | at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)ispn-lon-1 | at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)ispn-lon-1 | at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)ispn-lon-1 | at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)ispn-lon-1 | at org.infinispan.remoting.transport.AbstractRequest.complete(AbstractRequest.java:67)ispn-lon-1 | at org.infinispan.remoting.transport.impl.MultiTargetRequest.onResponse(MultiTargetRequest.java:105)ispn-lon-1 | at org.infinispan.remoting.transport.impl.RequestRepository.addResponse(RequestRepository.java:51)ispn-lon-1 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport.processResponse(JGroupsTransport.java:1407)ispn-lon-1 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport.processMessage(JGroupsTransport.java:1310)ispn-lon-1 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport.access$300(JGroupsTransport.java:131)ispn-lon-1 | at org.infinispan.remoting.transport.jgroups.JGroupsTransport$ChannelCallbacks.up(JGroupsTransport.java:1450)ispn-lon-1 | at org.jgroups.JChannel.up(JChannel.java:784)ispn-lon-1 | at org.jgroups.stack.ProtocolStack.up(ProtocolStack.java:913)ispn-lon-1 | at org.jgroups.protocols.relay.RELAY2.up(RELAY2.java:499)ispn-lon-1 | at org.jgroups.protocols.FRAG3.up(FRAG3.java:165)ispn-lon-1 | at org.jgroups.protocols.FlowControl.up(FlowControl.java:343)ispn-lon-1 | at org.jgroups.protocols.FlowControl.up(FlowControl.java:343)ispn-lon-1 | at org.jgroups.protocols.pbcast.GMS.up(GMS.java:876)ispn-lon-1 | at org.jgroups.protocols.pbcast.STABLE.up(STABLE.java:243)ispn-lon-1 | at org.jgroups.protocols.UNICAST3.deliverMessage(UNICAST3.java:1049)ispn-lon-1 | at org.jgroups.protocols.UNICAST3.addMessage(UNICAST3.java:772)ispn-lon-1 | at org.jgroups.protocols.UNICAST3.handleDataReceived(UNICAST3.java:753)ispn-lon-1 | at org.jgroups.protocols.UNICAST3.up(UNICAST3.java:405)ispn-lon-1 | at org.jgroups.protocols.pbcast.NAKACK2.up(NAKACK2.java:592)ispn-lon-1 | at org.jgroups.protocols.VERIFY_SUSPECT.up(VERIFY_SUSPECT.java:132)ispn-lon-1 | at org.jgroups.protocols.FailureDetection.up(FailureDetection.java:186)ispn-lon-1 | at org.jgroups.protocols.FD_SOCK.up(FD_SOCK.java:254)ispn-lon-1 | at org.jgroups.protocols.MERGE3.up(MERGE3.java:281)ispn-lon-1 | at org.jgroups.protocols.Discovery.up(Discovery.java:300)ispn-lon-1 | at org.jgroups.protocols.TP.passMessageUp(TP.java:1396)ispn-lon-1 | at org.jgroups.util.SubmitToThreadPool$SingleMessageHandler.run(SubmitToThreadPool.java:87)ispn-lon-1 | at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)ispn-lon-1 | at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)ispn-lon-1 | at java.base/java.lang.Thread.run(Thread.java:834)}}
--
This message was sent by Atlassian Jira
(v8.13.1#813001)
5 years, 3 months
[Red Hat JIRA] (ISPN-12638) Make NonBlockingStore.delete() return CompletionStage<Void>
by Dan Berindei (Jira)
Dan Berindei created ISPN-12638:
-----------------------------------
Summary: Make NonBlockingStore.delete() return CompletionStage<Void>
Key: ISPN-12638
URL: https://issues.redhat.com/browse/ISPN-12638
Project: Infinispan
Issue Type: Enhancement
Components: API, Loaders and Stores
Affects Versions: 12.0.0.CR1
Reporter: Dan Berindei
Assignee: Dan Berindei
{{NonBlockingStore.delete(int segment, Object key)}} returns a {{CompletionStage<Boolean>}}, just like {{CacheWriter.delete(Object key)}} returns a {{boolean}}. But the {{Boolean}} return value is not used, so it could be replaced with {{Void}}.
In {{CacheWriterInterceptor}}, the return value of the remove command is based only on the value that was loaded in the invocation context, not on the result of the store delete operation:
https://github.com/infinispan/infinispan/blob/7206596b4a0258d0b8f1a20d782...
Same with the {{removeHits}} statistic in {{CacheMgmtInterceptor}}:
https://github.com/infinispan/infinispan/blob/2d53d0a1e59f2dc3335235f9daf...
Changing the return value to {{CompletionStage<Void>}} would improve performance in some stores, e.g. {{RocksDBStore}} wouldn't have to read the value first. And the async store can't return the result of the actual deletion anyway.
--
This message was sent by Atlassian Jira
(v8.13.1#813001)
5 years, 3 months
[Red Hat JIRA] (ISPN-12637) Remove superfluous config example from eviction content
by Will Burns (Jira)
[ https://issues.redhat.com/browse/ISPN-12637?page=com.atlassian.jira.plugi... ]
Will Burns updated ISPN-12637:
------------------------------
Resolution: Done
Status: Resolved (was: Pull Request Sent)
> Remove superfluous config example from eviction content
> -------------------------------------------------------
>
> Key: ISPN-12637
> URL: https://issues.redhat.com/browse/ISPN-12637
> Project: Infinispan
> Issue Type: Enhancement
> Components: Documentation
> Affects Versions: 12.0.0.CR1
> Reporter: Donald Naro
> Assignee: Donald Naro
> Priority: Major
> Fix For: 12.0.0.Final, 11.0.10.Final
>
>
> https://infinispan.org/docs/stable/titles/configuring/configuring.html#cu...
> Remove the following section from the configuration guide:
> Custom Classes with Memory-Based Eviction
> You must use binary or off-heap storage memory based eviction, as in the following examples:
> Declarative configuration
> <!-- Enable memory based eviction with 1 GB/> -->
> <memory>
> <binary size="1000000000" eviction="MEMORY"/>
> </memory>
> Programmatic configuration
> Configuration c = new ConfigurationBuilder()
> .memory()
> .storageType(StorageType.BINARY)
> .evictionType(EvictionType.MEMORY)
> .size(1_000_000_000)
> .build();
--
This message was sent by Atlassian Jira
(v8.13.1#813001)
5 years, 3 months
[Red Hat JIRA] (ISPN-12637) Remove superfluous config example from eviction content
by Donald Naro (Jira)
[ https://issues.redhat.com/browse/ISPN-12637?page=com.atlassian.jira.plugi... ]
Donald Naro updated ISPN-12637:
-------------------------------
Description:
https://infinispan.org/docs/stable/titles/configuring/configuring.html#cu...
Remove the following section from the configuration guide:
Custom Classes with Memory-Based Eviction
You must use binary or off-heap storage memory based eviction, as in the following examples:
Declarative configuration
<!-- Enable memory based eviction with 1 GB/> -->
<memory>
<binary size="1000000000" eviction="MEMORY"/>
</memory>
Programmatic configuration
Configuration c = new ConfigurationBuilder()
.memory()
.storageType(StorageType.BINARY)
.evictionType(EvictionType.MEMORY)
.size(1_000_000_000)
.build();
was:
Protostream 4.4.0.Alpha4 added support for automatically generating marshallers for external classes via the {{@ProtoAdaptor}} field. This greatly simplifies how a user can marshall third party classes, as it's no longer necessary to implement the {{MessageMarshaller}} interface and explicitly create a {{SerializationContextInitializer}} implementation.
Process for using {{@ProtoAdaptor}}
1. Create an adaptor class and add the {{@ProtoAdaptor}} annotation
{code:java}
@ProtoAdapter(UUID.class)
public class UUIDAdapter {
@ProtoFactory
UUID create(Long mostSigBitsFixed, Long leastSigBitsFixed) {
return new UUID(mostSigBitsFixed, leastSigBitsFixed);
}
@ProtoField(number = 1, type = Type.FIXED64, defaultValue = "0")
Long getMostSigBitsFixed(UUID uuid) {
return uuid.getMostSignificantBits();
}
@ProtoField(number = 2, type = Type.FIXED64, defaultValue = "0")
Long getLeastSigBitsFixed(UUID uuid) {
return uuid.getLeastSignificantBits();
}
}
{code}
2. Register {{UUIDAdapter}} with your {{SerialiazationContextInitializer}} interface (LibraryInitializer in the docs examples).
> Remove superfluous config example from eviction content
> -------------------------------------------------------
>
> Key: ISPN-12637
> URL: https://issues.redhat.com/browse/ISPN-12637
> Project: Infinispan
> Issue Type: Task
> Components: Documentation
> Affects Versions: 12.0.0.CR1
> Reporter: Donald Naro
> Assignee: Donald Naro
> Priority: Major
> Fix For: 12.0.0.Final
>
>
> https://infinispan.org/docs/stable/titles/configuring/configuring.html#cu...
> Remove the following section from the configuration guide:
> Custom Classes with Memory-Based Eviction
> You must use binary or off-heap storage memory based eviction, as in the following examples:
> Declarative configuration
> <!-- Enable memory based eviction with 1 GB/> -->
> <memory>
> <binary size="1000000000" eviction="MEMORY"/>
> </memory>
> Programmatic configuration
> Configuration c = new ConfigurationBuilder()
> .memory()
> .storageType(StorageType.BINARY)
> .evictionType(EvictionType.MEMORY)
> .size(1_000_000_000)
> .build();
--
This message was sent by Atlassian Jira
(v8.13.1#813001)
5 years, 3 months