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

RemoteListener doesn't work with StorageType.BINARY/StorageType.OFF_HEAP

    Details

    • Steps to Reproduce:
      Hide

      1- Use attached clustered.xml when starts RHDG instance (It is out-the-box file but with JDG_SERIALIZATION_TEST cache added)
      2- Unzip jdg-serialization-error.zip
      3- Open src/test/java/com/redhat/jdg/SerializationTests.java and update IP.
      4- In jdg-serialization-error folder execute maven test command mvn -Dtest=SerializationTests test

      Show
      1- Use attached clustered.xml when starts RHDG instance (It is out-the-box file but with JDG_SERIALIZATION_TEST cache added) 2- Unzip jdg-serialization-error.zip 3- Open src/test/java/com/redhat/jdg/SerializationTests.java and update IP. 4- In jdg-serialization-error folder execute maven test command mvn -Dtest=SerializationTests test

      Description

      Customer has a cache configuration that uses nearCache builder. When try to get the value using cache.get(KEY), get the following message before get the value:

      -------------------------------------------------------------
      [Retrieve Bean] Retrieve key='KEY' —
      Sep 20, 2019 7:15:28 PM org.infinispan.client.hotrod.impl.transport.netty.HeaderDecoder decode
      WARN: ISPN004039: Unable to complete reading event from server 192.168.1.5/192.168.1.5:11222
      org.infinispan.client.hotrod.exceptions.HotRodClientException:: ISPN004034: Unable to unmarshall bytes 01012905033E034B4559
      at org.infinispan.client.hotrod.marshall.MarshallerUtil.bytes2obj(MarshallerUtil.java:47)
      at org.infinispan.client.hotrod.DataFormat.keyToObj(DataFormat.java:103)
      at org.infinispan.client.hotrod.impl.protocol.Codec21.readCacheEvent(Codec21.java:79)
      at org.infinispan.client.hotrod.impl.transport.netty.HeaderDecoder.decode(HeaderDecoder.java:153)
      at org.infinispan.client.hotrod.impl.transport.netty.HintedReplayingDecoder.callDecode(HintedReplayingDecoder.java:98)
      at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:265)
      at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
      at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
      at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
      at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286)
      at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
      at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
      at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
      at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
      at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
      at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
      at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
      at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:808)
      at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:417)
      at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:317)
      at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:884)
      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.io.IOException: Unsupported protocol version 1
      at org.jboss.marshalling.river.RiverUnmarshaller.start(RiverUnmarshaller.java:1349)
      at org.infinispan.commons.marshall.jboss.AbstractJBossMarshaller.startObjectInput(AbstractJBossMarshaller.java:129)
      at org.infinispan.commons.marshall.jboss.AbstractJBossMarshaller.objectFromByteBuffer(AbstractJBossMarshaller.java:110)
      at org.infinispan.commons.marshall.AbstractMarshaller.objectFromByteBuffer(AbstractMarshaller.java:82)
      at org.infinispan.client.hotrod.marshall.MarshallerUtil.bytes2obj(MarshallerUtil.java:31)
      ... 23 more

      [Retrieve Bean] Value is 'VALUE' —
      -------------------------------------------------------------

      That doesn't impact the process of getting the stored value, but gets the WARN message with every query to that cache. The message is only generated when uses nearCahche

        Gliffy Diagrams

          Attachments

            Activity

              People

              • Assignee:
                gustavonalle Gustavo Fernandes
                Reporter:
                william.burns Will Burns
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: