3

我正在使用apache cassandra 2.2.4. 我有一个 4(四)节点集群,DC1 中的复制因子为 3,DC2 中的复制因子为 1,其中 DC1 包含 3(三)个节点,DC2 包含 1(一)个节点。在这个集群中之前还有一些节点,但由于某种原因,我删除了它们并且没有改变复制方案。[请注意以下IP不是原创]

Datacenter: DC1
===============
Status=Up/Down
|/ State=Normal/Leaving/Joining/Moving
--  Address        Load       Tokens       Owns    Host ID                               Rack
UN  21.12.19.91    4.08 GB    256          ?       a45bb676-1ddd-4b22-933b-58653cea680f  RAC1
UN  21.12.19.92    3.92 GB    256          ?       a7735fca-8671-4a20-a759-4a2681aed37e  RAC1
UN  21.12.19.93    4.47 GB    256          ?       d98f3cad-881a-41c8-89c7-170c63c3d236  RAC1
Datacenter: DC2
===============
Status=Up/Down
|/ State=Normal/Leaving/Joining/Moving
--  Address        Load       Tokens       Owns    Host ID                               Rack
UN  21.12.19.99    3.84 GB    256          ?       ccd9ca97-f97a-4473-9a65-49b12a1b60ba  RAC1

集群工作正常,但现在我遇到了INFO. 我试图分析这个问题,但还没有做到。有没有人熟悉以下场景?

INFO  [SharedPool-Worker-2] 2017-02-26 06:56:48,520 Message.java:605 - Unexpected exception during request; channel = [id: 0x637a702c, /18.12.10.17:60926 :> /21.12.19.91:9042]
java.io.IOException: Error while read(...): Connection reset by peer
    at io.netty.channel.epoll.Native.readAddress(Native Method) ~[netty-all-4.0.23.Final.jar:4.0.23.Final]
    at io.netty.channel.epoll.EpollSocketChannel$EpollSocketUnsafe.doReadBytes(EpollSocketChannel.java:675) ~[netty-all-4.0.23.Final.jar:4.0.23.Final]
    at io.netty.channel.epoll.EpollSocketChannel$EpollSocketUnsafe.epollInReady(EpollSocketChannel.java:714) ~[netty-all-4.0.23.Final.jar:4.0.23.Final]
    at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:326) ~[netty-all-4.0.23.Final.jar:4.0.23.Final]
    at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:264) ~[netty-all-4.0.23.Final.jar:4.0.23.Final]
    at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) ~[netty-all-4.0.23.Final.jar:4.0.23.Final]
    at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137) ~[netty-all-4.0.23.Final.jar:4.0.23.Final]
    at java.lang.Thread.run(Thread.java:745) [na:1.8.0_66]
4

1 回答 1

0

请确保您的防火墙没有丢弃正在使用的 TCP 连接。所有节点上的 Tcp keep alive 必须小于防火墙设置。有关 TCP 设置的详细信息,请参阅https://docs.datastax.com/en/cassandra/2.0/cassandra/troubleshooting/trblshootIdleFirewall.html。这帮助我解决了这个问题。

于 2017-03-02T00:53:38.833 回答