Uploaded image for project: 'Infinispan'
  1. Infinispan
  2. ISPN-9871

Error executing command PutKeyValueCommand when using protobuf

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Critical
    • 10.0.0.Alpha3, 9.4.6.Final
    • 9.4.5.Final
    • None
    • None

    Description

      private final String KEY = "key";
builder.addServer().host("127.0.0.1").port(11222).marshaller(new ProtoStreamMarshaller());
ProtobufHelper.register(cacheManager, "/library.proto");
RemoteCache cache = cacheManager.getCache("DEVICES");
cache.put(KEY + counter++, new Person("foo" + counter, counter));

      Server1 - Stacktrace

      10:34:07,799 ERROR [org.infinispan.interceptors.impl.InvocationContextInterceptor] (jgroups-6,diegos-macbook-pro) ISPN000136: Error executing command PutKeyValueCommand, writing keys [WrappedByteArray{bytes=[B0x4A076B6579333339..[9], hashCode=1989086686}]: org.infinispan.remoting.RemoteException: ISPN000217: Received exception from diegos-macbook-pro, see cause for remote stack trace
    at org.infinispan.remoting.transport.ResponseCollectors.wrapRemoteException(ResponseCollectors.java:27)
    at org.infinispan.remoting.transport.ValidSingleResponseCollector.withException(ValidSingleResponseCollector.java:37)
    at org.infinispan.remoting.transport.ValidSingleResponseCollector.addResponse(ValidSingleResponseCollector.java:21)
    at org.infinispan.remoting.transport.impl.SingleTargetRequest.receiveResponse(SingleTargetRequest.java:52)
    at org.infinispan.remoting.transport.impl.SingleTargetRequest.onResponse(SingleTargetRequest.java:35)
    at org.infinispan.remoting.transport.impl.RequestRepository.addResponse(RequestRepository.java:52)
    at org.infinispan.remoting.transport.jgroups.JGroupsTransport.processResponse(JGroupsTransport.java:1372)
    at org.infinispan.remoting.transport.jgroups.JGroupsTransport.processMessage(JGroupsTransport.java:1275)
    at org.infinispan.remoting.transport.jgroups.JGroupsTransport.access$300(JGroupsTransport.java:126)
    at org.infinispan.remoting.transport.jgroups.JGroupsTransport$ChannelCallbacks.up(JGroupsTransport.java:1420)
    at org.jgroups.JChannel.up(JChannel.java:816)
    at org.jgroups.fork.ForkProtocolStack.up(ForkProtocolStack.java:133)
    at org.jgroups.stack.Protocol.up(Protocol.java:340)
    at org.jgroups.protocols.FORK.up(FORK.java:141)
    at org.jgroups.protocols.FRAG3.up(FRAG3.java:171)
    at org.jgroups.protocols.FlowControl.up(FlowControl.java:343)
    at org.jgroups.protocols.FlowControl.up(FlowControl.java:343)
    at org.jgroups.protocols.pbcast.GMS.up(GMS.java:873)
    at org.jgroups.protocols.pbcast.STABLE.up(STABLE.java:240)
    at org.jgroups.protocols.UNICAST3.deliverMessage(UNICAST3.java:1003)
    at org.jgroups.protocols.UNICAST3.handleDataReceived(UNICAST3.java:729)
    at org.jgroups.protocols.UNICAST3.up(UNICAST3.java:384)
    at org.jgroups.protocols.pbcast.NAKACK2.up(NAKACK2.java:600)
    at org.jgroups.protocols.VERIFY_SUSPECT.up(VERIFY_SUSPECT.java:130)
    at org.jgroups.protocols.FD_ALL.up(FD_ALL.java:203)
    at org.jgroups.protocols.FD_SOCK.up(FD_SOCK.java:253)
    at org.jgroups.protocols.MERGE3.up(MERGE3.java:280)
    at org.jgroups.protocols.Discovery.up(Discovery.java:269)
    at org.jgroups.protocols.TP.passMessageUp(TP.java:1248)
    at org.jgroups.util.SubmitToThreadPool$SingleMessageHandler.run(SubmitToThreadPool.java:87)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.IllegalArgumentException: Descriptor not found : jira_verification.Person
    at org.infinispan.protostream.impl.SerializationContextImpl.getDescriptorByName(SerializationContextImpl.java:334)
    at org.infinispan.query.remote.impl.indexing.WrappedMessageTagHandler.onTag(WrappedMessageTagHandler.java:67)
    at org.infinispan.protostream.ProtobufParser.parseMessage(ProtobufParser.java:75)
    at org.infinispan.protostream.ProtobufParser.parseInternal(ProtobufParser.java:57)
    at org.infinispan.protostream.ProtobufParser.parse(ProtobufParser.java:44)
    at org.infinispan.query.remote.impl.indexing.ProtobufValueWrapperSearchWorkCreator.discoverMessageType(ProtobufValueWrapperSearchWorkCreator.java:90)
    at org.infinispan.query.remote.impl.indexing.ProtobufValueWrapperSearchWorkCreator.interceptValue(ProtobufValueWrapperSearchWorkCreator.java:77)
    at org.infinispan.query.remote.impl.indexing.ProtobufValueWrapperSearchWorkCreator.access$300(ProtobufValueWrapperSearchWorkCreator.java:27)
    at org.infinispan.query.remote.impl.indexing.ProtobufValueWrapperSearchWorkCreator$Delegate.createPerEntityWorks(ProtobufValueWrapperSearchWorkCreator.java:57)
    at org.infinispan.query.backend.QueryInterceptor.performSearchWork(QueryInterceptor.java:377)
    at org.infinispan.query.backend.QueryInterceptor.updateIndexes(QueryInterceptor.java:372)
    at org.infinispan.query.backend.QueryInterceptor.processChange(QueryInterceptor.java:455)
    at org.infinispan.query.backend.QueryInterceptor.lambda$handleDataWriteCommand$0(QueryInterceptor.java:188)
    at org.infinispan.interceptors.InvocationSuccessAction.apply(InvocationSuccessAction.java:22)
    at org.infinispan.interceptors.impl.QueueAsyncInvocationStage.invokeQueuedHandlers(QueueAsyncInvocationStage.java:118)
    at org.infinispan.interceptors.impl.QueueAsyncInvocationStage.accept(QueueAsyncInvocationStage.java:81)
    at org.infinispan.interceptors.impl.QueueAsyncInvocationStage.accept(QueueAsyncInvocationStage.java:30)
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
    at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962)
    at org.infinispan.remoting.transport.AbstractRequest.complete(AbstractRequest.java:67)
    at org.infinispan.remoting.transport.impl.MultiTargetRequest.onResponse(MultiTargetRequest.java:102)
    ... 28 more

      Server2

      10:34:05,473 ERROR [org.infinispan.interceptors.impl.InvocationContextInterceptor] (stateTransferExecutor-thread--p5-t38) ISPN000136: Error executing command PutKeyValueCommand, writing keys [/library.proto]: org.infinispan.commons.CacheException: ISPN028008: The value must be a String : class org.infinispan.container.entries.metadata.MetadataImmortalCacheEntry
    at org.infinispan.query.remote.impl.ProtobufMetadataManagerInterceptor.visitPutKeyValueCommand(ProtobufMetadataManagerInterceptor.java:219)
    at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:69)
    at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:54)
    at org.infinispan.interceptors.locking.AbstractTxLockingInterceptor.lambda$new$0(AbstractTxLockingInterceptor.java:34)
    at org.infinispan.interceptors.InvocationSuccessFunction.apply(InvocationSuccessFunction.java:25)
    at org.infinispan.interceptors.SyncInvocationStage.addCallback(SyncInvocationStage.java:42)
    at org.infinispan.interceptors.InvocationStage.thenApply(InvocationStage.java:45)
    at org.infinispan.interceptors.locking.PessimisticLockingInterceptor.acquireLocalLockAndInvokeNext(PessimisticLockingInterceptor.java:283)
    at org.infinispan.interceptors.locking.PessimisticLockingInterceptor.visitDataWriteCommand(PessimisticLockingInterceptor.java:148)
    at org.infinispan.interceptors.locking.AbstractLockingInterceptor.visitPutKeyValueCommand(AbstractLockingInterceptor.java:82)
    at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:69)
    at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextAndFinally(BaseAsyncInterceptor.java:150)
    at org.infinispan.interceptors.impl.TxInterceptor.handleWriteCommand(TxInterceptor.java:402)
    at org.infinispan.interceptors.impl.TxInterceptor.visitPutKeyValueCommand(TxInterceptor.java:235)
    at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:69)
    at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:54)
    at org.infinispan.statetransfer.TransactionSynchronizerInterceptor.visitCommand(TransactionSynchronizerInterceptor.java:41)
    at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextAndHandle(BaseAsyncInterceptor.java:185)
    at org.infinispan.statetransfer.StateTransferInterceptor.handleTxWriteCommand(StateTransferInterceptor.java:260)
    at org.infinispan.statetransfer.StateTransferInterceptor.handleWriteCommand(StateTransferInterceptor.java:250)
    at org.infinispan.statetransfer.StateTransferInterceptor.visitPutKeyValueCommand(StateTransferInterceptor.java:96)
    at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:69)
    at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:54)
    at org.infinispan.interceptors.impl.CacheMgmtInterceptor.updateStoreStatistics(CacheMgmtInterceptor.java:214)
    at org.infinispan.interceptors.impl.CacheMgmtInterceptor.visitPutKeyValueCommand(CacheMgmtInterceptor.java:179)
    at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:69)
    at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextAndExceptionally(BaseAsyncInterceptor.java:123)
    at org.infinispan.interceptors.impl.InvocationContextInterceptor.visitCommand(InvocationContextInterceptor.java:90)
    at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:56)
    at org.infinispan.interceptors.impl.BatchingInterceptor.handleDefault(BatchingInterceptor.java:69)
    at org.infinispan.interceptors.impl.BatchingInterceptor.visitPutKeyValueCommand(BatchingInterceptor.java:49)
    at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:69)
    at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:54)
    at org.infinispan.interceptors.DDAsyncInterceptor.handleDefault(DDAsyncInterceptor.java:54)
    at org.infinispan.interceptors.DDAsyncInterceptor.visitPutKeyValueCommand(DDAsyncInterceptor.java:60)
    at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:69)
    at org.infinispan.interceptors.DDAsyncInterceptor.visitCommand(DDAsyncInterceptor.java:50)
    at org.infinispan.interceptors.impl.AsyncInterceptorChainImpl.invoke(AsyncInterceptorChainImpl.java:248)
    at org.infinispan.statetransfer.StateConsumerImpl.doApplyState(StateConsumerI

      Attachments

        Issue Links

          is caused by

          Enhancement - An enhancement to or refactoring of existing functionality that is not configurable by an end user (typically a change made by an internal team that affects users) ISPN-4075 State transfer should preserve the creation timestamp of entries

          • Major - To be worked after higher priority work items are addressed. When the severity is high and the effort to change it is low to moderate, this term is chosen. Issues in this category likely have an existing workaround but implementation or execution may be non-trivial.
          • Closed

          Activity

            People

              dberinde@redhat.com Dan Berindei (Inactive)
              dlovison@redhat.com Diego Lovison
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: