[
https://issues.apache.org/jira/browse/AVRO-2874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167090#comment-17167090
]
Raghupal Reddy edited comment on AVRO-2874 at 7/29/20, 9:43 AM:
----------------------------------------------------------------
[~rskraba] Thanks for your response
Here is my use-case
_NettyServer server = new NettyServer(new
SpecificResponder(SystemConfigurationController.class, new
SystemConfigurationControllerImpl()), new InetSocketAddress(64020));_
//SystemConfigurationControllerImpl -> Implementation to control linux system
settings
// Client
_NettyTransceiver systemControllerClient = new NettyTransceiver(new
InetSocketAddress(InetAddress.getLoopbackAddress(), 64020));_
_SystemConfigurationController systemController =
SpecificRequestor.getClient(SystemConfigurationController.class,
systemControllerClient);_
_systemController.setXXX();_
I have added Netty 3.10.6.Final dependency but issue still exists, here is the
new stack trace
*Just FYI, this functionality is working fine with avro-ipc-1.7.7 jar (Avro
1.7.7 jars)*
2020-07-28 18:25:53,482 | INFO | server boss #13 | NettyServer | 47 -
avro-ipc-netty - 1.9.2 | [id: 0xa3b9eff1, /127.0.0.1:56066 => /127.0.0.1:64020]
OPEN
2020-07-28 18:25:53,485 | INFO | ew I/O worker #3 | NettyServer | 47 -
avro-ipc-netty - 1.9.2 | [id: 0xa3b9eff1, /127.0.0.1:56066 => /127.0.0.1:64020]
BOUND: /127.0.0.1:64020
2020-07-28 18:25:53,485 | INFO | ew I/O worker #3 | NettyServer | 47 -
avro-ipc-netty - 1.9.2 | [id: 0xa3b9eff1, /127.0.0.1:56066 => /127.0.0.1:64020]
CONNECTED: /127.0.0.1:56066
2020-07-28 18:25:54,272 | WARN | ew I/O worker #3 | Responder | 56 - avro-ipc
- 1.9.2 | system error
java.lang.ClassCastException: org.apache.avro.generic.GenericData$Record
cannot be cast to org.apache.avro.ipc.HandshakeRequest
at
org.apache.avro.ipc.Responder.handshake(Responder.java:209)[56:avro-ipc:1.9.2]
at org.apache.avro.ipc.Responder.respond(Responder.java:120)[56:avro-ipc:1.9.2]
at
org.apache.avro.ipc.netty.NettyServer$NettyServerAvroHandler.messageReceived(NettyServer.java:173)[47:avro-ipc-netty:1.9.2]
at
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)[41:org.jboss.netty:3.10.6.Final]
at
org.apache.avro.ipc.netty.NettyServer$NettyServerAvroHandler.handleUpstream(NettyServer.java:159)[47:avro-ipc-netty:1.9.2]
at
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:462)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:443)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:303)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)[41:org.jboss.netty:3.10.6.Final]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)[:1.8.0_242]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)[:1.8.0_242]
at java.lang.Thread.run(Thread.java:748)[:1.8.0_242]
2020-07-28 18:25:54,672 | INFO | ew I/O worker #3 | NettyServer | 47 -
avro-ipc-netty - 1.9.2 | [id: 0xa3b9eff1, /127.0.0.1:56066 :> /127.0.0.1:64020]
DISCONNECTED
2020-07-28 18:25:54,673 | INFO | ew I/O worker #3 | NettyServer | 47 -
avro-ipc-netty - 1.9.2 | [id: 0xa3b9eff1, /127.0.0.1:56066 :> /127.0.0.1:64020]
UNBOUND
2020-07-28 18:25:54,673 | INFO | ew I/O worker #3 | NettyServer | 47 -
avro-ipc-netty - 1.9.2 | [id: 0xa3b9eff1, /127.0.0.1:56066 :> /127.0.0.1:64020]
CLOSED
2020-07-28 18:25:54,673 | INFO | ew I/O worker #3 | NettyServer | 47 -
avro-ipc-netty - 1.9.2 | Connection to /127.0.0.1:56066 disconnected.
was (Author: raghupalreddy):
[~rskraba] Thanks for your response
Here is my use-case
_NettyServer server = new NettyServer(new
SpecificResponder(SystemConfigurationController.class, new
SystemConfigurationControllerImpl()), new InetSocketAddress(64020));_
//SystemConfigurationControllerImpl -> Implementation to control linux system
settings
// Client
_NettyTransceiver systemControllerClient = new NettyTransceiver(new
InetSocketAddress(InetAddress.getLoopbackAddress(), 64020));_
_SystemConfigurationController systemController =
SpecificRequestor.getClient(SystemConfigurationController.class,
systemControllerClient);_
_systemController.setXXX();_
I have added Netty 3.10.6.Final dependency but issue still exists, here is the
new stack trace
*Just FYI, same functionality is working fine with avro-ipc-1.7.7 jar (Avro
1.7.7 jars)*
2020-07-28 18:25:53,482 | INFO | server boss #13 | NettyServer | 47 -
avro-ipc-netty - 1.9.2 | [id: 0xa3b9eff1, /127.0.0.1:56066 => /127.0.0.1:64020]
OPEN
2020-07-28 18:25:53,485 | INFO | ew I/O worker #3 | NettyServer | 47 -
avro-ipc-netty - 1.9.2 | [id: 0xa3b9eff1, /127.0.0.1:56066 => /127.0.0.1:64020]
BOUND: /127.0.0.1:64020
2020-07-28 18:25:53,485 | INFO | ew I/O worker #3 | NettyServer | 47 -
avro-ipc-netty - 1.9.2 | [id: 0xa3b9eff1, /127.0.0.1:56066 => /127.0.0.1:64020]
CONNECTED: /127.0.0.1:56066
2020-07-28 18:25:54,272 | WARN | ew I/O worker #3 | Responder | 56 - avro-ipc -
1.9.2 | system error
java.lang.ClassCastException: org.apache.avro.generic.GenericData$Record cannot
be cast to org.apache.avro.ipc.HandshakeRequest
at
org.apache.avro.ipc.Responder.handshake(Responder.java:209)[56:avro-ipc:1.9.2]
at org.apache.avro.ipc.Responder.respond(Responder.java:120)[56:avro-ipc:1.9.2]
at
org.apache.avro.ipc.netty.NettyServer$NettyServerAvroHandler.messageReceived(NettyServer.java:173)[47:avro-ipc-netty:1.9.2]
at
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)[41:org.jboss.netty:3.10.6.Final]
at
org.apache.avro.ipc.netty.NettyServer$NettyServerAvroHandler.handleUpstream(NettyServer.java:159)[47:avro-ipc-netty:1.9.2]
at
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:462)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:443)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:303)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)[41:org.jboss.netty:3.10.6.Final]
at
org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)[41:org.jboss.netty:3.10.6.Final]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)[:1.8.0_242]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)[:1.8.0_242]
at java.lang.Thread.run(Thread.java:748)[:1.8.0_242]
2020-07-28 18:25:54,672 | INFO | ew I/O worker #3 | NettyServer | 47 -
avro-ipc-netty - 1.9.2 | [id: 0xa3b9eff1, /127.0.0.1:56066 :> /127.0.0.1:64020]
DISCONNECTED
2020-07-28 18:25:54,673 | INFO | ew I/O worker #3 | NettyServer | 47 -
avro-ipc-netty - 1.9.2 | [id: 0xa3b9eff1, /127.0.0.1:56066 :> /127.0.0.1:64020]
UNBOUND
2020-07-28 18:25:54,673 | INFO | ew I/O worker #3 | NettyServer | 47 -
avro-ipc-netty - 1.9.2 | [id: 0xa3b9eff1, /127.0.0.1:56066 :> /127.0.0.1:64020]
CLOSED
2020-07-28 18:25:54,673 | INFO | ew I/O worker #3 | NettyServer | 47 -
avro-ipc-netty - 1.9.2 | Connection to /127.0.0.1:56066 disconnected.
> java.lang.ClassCastException: org.apache.avro.generic.GenericData$Record
> cannot be cast to org.apache.avro.ipc.HandshakeRequest
> -------------------------------------------------------------------------------------------------------------------------------
>
> Key: AVRO-2874
> URL: https://issues.apache.org/jira/browse/AVRO-2874
> Project: Apache Avro
> Issue Type: Bug
> Components: java
> Affects Versions: 1.9.2
> Reporter: Raghupal Reddy
> Priority: Blocker
>
> Hi,
> Here is the stack trace
> 2020-06-29 05:00:34,712 | WARN | w I/O worker #11 | Responder
> | 56 - avro-ipc - 1.9.2 | system error2020-06-29 05:00:34,712 | WARN
> | w I/O worker #11 | Responder | 56 - avro-ipc - 1.9.2
> | system errorjava.lang.ClassCastException:
> org.apache.avro.generic.GenericData$Record cannot be cast to
> org.apache.avro.ipc.HandshakeRequest at
> org.apache.avro.ipc.Responder.handshake(Responder.java:209)[56:avro-ipc:1.9.2]
> at
> org.apache.avro.ipc.Responder.respond(Responder.java:120)[56:avro-ipc:1.9.2]
> at
> org.apache.avro.ipc.netty.NettyServer$NettyServerAvroHandler.messageReceived(NettyServer.java:173)[47:avro-ipc-netty:1.9.2]
> at
> org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)[41:org.jboss.netty:3.10.0.Final]
> at
> org.apache.avro.ipc.netty.NettyServer$NettyServerAvroHandler.handleUpstream(NettyServer.java:159)[47:avro-ipc-netty:1.9.2]
> at
> org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)[41:org.jboss.netty:3.10.0.Final]
> at
> org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)[41:org.jboss.netty:3.10.0.Final]
> at
> org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)[41:org.jboss.netty:3.10.0.Final]
> at
> org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:462)[41:org.jboss.netty:3.10.0.Final]
> at
> org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:443)[41:org.jboss.netty:3.10.0.Final]
> at
> org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:303)[41:org.jboss.netty:3.10.0.Final]
> at
> org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)[41:org.jboss.netty:3.10.0.Final]
> at
> org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)[41:org.jboss.netty:3.10.0.Final]
> at
> org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)[41:org.jboss.netty:3.10.0.Final]
> at
> org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)[41:org.jboss.netty:3.10.0.Final]
> at
> org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)[41:org.jboss.netty:3.10.0.Final]
> at
> org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)[41:org.jboss.netty:3.10.0.Final]
> at
> org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)[41:org.jboss.netty:3.10.0.Final]
> at
> org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)[41:org.jboss.netty:3.10.0.Final]
> at
> org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)[41:org.jboss.netty:3.10.0.Final]
> at
> org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)[41:org.jboss.netty:3.10.0.Final]
> at
> org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)[41:org.jboss.netty:3.10.0.Final]
> at
> org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)[41:org.jboss.netty:3.10.0.Final]
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)[:1.8.0_252]
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)[:1.8.0_252]
> at java.lang.Thread.run(Thread.java:748)[:1.8.0_252]
>
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
