开发者社区> 问答> 正文

咨询一个问题,我现在扩容的时候,4+4,扩到第三个节点了,报错了,如下图,这个问题是怎么导致的啊?

咨询一个问题,我现在扩容的时候,4+4,扩到第三个节点了,报错了,如下图,这个问题是怎么导致的啊,我该怎么去处理,现在我在对 106 (报错的这个节点)进行repair,能否有效呢?

WARN [STREAM-IN-/172.16.3.106:7000] 2022-06-03 23:13:04,464 CompressedStreamReader.java:119 - [Stream dc9c4550-e0a4-11ec-8333-4d343570aec2] Error while reading partition DecoratedKey(-1734359418124195320, 0010270b3b5ec73248c1a6f8512a0ff43e6e000004000001f600) from stream on ks='rzbigdata' and table='dat_indexdatas'. ERROR [STREAM-IN-/172.16.3.106:7000] 2022-06-03 23:13:05,005 StreamSession.java:593 - [Stream #dc9c4550-e0a4-11ec-8333-4d343570aec2] Streaming error occurred on session with peer 172.16.3.106 java.io.IOException: net.jpountz.lz4.LZ4Exception: Error decoding offset 24121 of input buffer ······ at org.apache.cassandra.streaming.messages.StreamMessage.deserialize(StreamMessage.java:61) ~[apache-cassandra-3.11.4.jar:3.11.4] at org.apache.cassandra.streaming.ConnectionHandler$IncomingMessageHandler.run(ConnectionHandler.java:311) ~[apache-cassandra-3.11.4.jar:3.11.4] at java.lang.Thread.run(Thread.java:750) [na:1.8.0_322] Caused by: net.jpountz.lz4.LZ4Exception: Error decoding offset 24121 of input buffer at net.jpountz.lz4.LZ4JNIFastDecompressor.decompress(LZ4JNIFastDecompressor.java:39) ~[lz4-1.3.0.jar:na] at org.apache.cassandra.io.compress.LZ4Compressor.uncompress(LZ4Compressor.java:137) ~[apache-cassandra-3.11.4.jar:3.11.4] ... 31 common frames omitted

提问51.png

展开
收起
云上静思 2022-06-10 10:52:27 340 0
1 条回答
写回答
取消 提交回答
  • 106这台清洗下sstable再加新节点,repair有用。

    此答案来自钉钉群“Cassandra+Spark社区大群”。

    2022-06-10 22:36:16
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
图计算及其在阿里的应用 立即下载
图计算及在阿里应用 立即下载
动态、高效,蚂蚁动态卡片的内核逻辑 立即下载