Uploaded image for project: 'Red Hat Data Grid'
  1. Red Hat Data Grid
  2. JDG-3394

HotRod client will throw an Exception if a remote-task is executed in TaskExecutionMode.ALL_NODES

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Major
    • RHDG 8.4.1 GA
    • RHDG 8.2 GA, RHDG 8.3 GA
    • HotRod Java client
    • None

    Description

      If a remote task need protobuf marshalling and the TaskExecutionMode.ALL_NODES is active the return value to the client is not the ServerTask<K> K but ArrayList<K>.
      This will cause an Exception at client side, the server task is executed without any WARN/ERROR message in the servers logfiles.
      ~~~
      Dec 11, 2019 1:57:55 PM org.infinispan.client.hotrod.impl.protocol.Codec20 checkForErrorsInResponseStatus
      WARN: ISPN004005: Error received from the server: java.lang.IllegalArgumentException: No marshaller registered for java.util.ArrayList
      org.infinispan.client.hotrod.exceptions.HotRodClientException:Request for messageId=7 returned server error (status=0x85): java.lang.IllegalArgumentException: No marshaller registered for java.util.ArrayList
      at org.infinispan.client.hotrod.impl.protocol.Codec20.checkForErrorsInResponseStatus(Codec20.java:340)
      at org.infinispan.client.hotrod.impl.protocol.Codec20.readHeader(Codec20.java:177)
      at org.infinispan.client.hotrod.impl.transport.netty.HeaderDecoder.decode(HeaderDecoder.java:138)
      at org.infinispan.client.hotrod.impl.transport.netty.HintedReplayingDecoder.callDecode(HintedReplayingDecoder.java:98)
      at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:283)
      at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
      at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
      at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
      at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:287)
      at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
      at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
      at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
      at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1421)
      at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
      at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
      at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:930)
      at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:794)
      at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:424)
      at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:326)
      at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
      at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
      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)
      ~~~

      Attachments

        Issue Links

          Activity

            People

              remerson@redhat.com Ryan Emerson
              rhn-support-wfink Wolf Fink
              Anna Manukyan Anna Manukyan
              Votes:
              0 Vote for this issue
              Watchers:
              8 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: