java - 缩放cassandra流错误(空指针异常)

标签 java nullpointerexception cassandra

我们有一个包含大约 40GB 数据的单节点集群。我们正在尝试扩展并向集群添加第二个节点,但无法做到这一点。 种子节点开始传输数据,但一段时间后会抛出错误。 错误是:

ERROR [STREAM-OUT-/10.0.0.166] 2016-06-21 12:18:40,300 StreamSession.java:520 - [Stream #862ed0e0-37a7-11e6-b0b9-3fa2170fe9a5] Streaming error occurred
java.lang.NullPointerException: null
    at org.apache.cassandra.db.SerializationHeader$Component.access$500(SerializationHeader.java:283) ~[apache-cassandra-3.3.jar:3.3]
    at org.apache.cassandra.db.SerializationHeader$Serializer.serialize(SerializationHeader.java:430) ~[apache-cassandra-3.3.jar:3.3]
    at org.apache.cassandra.streaming.messages.FileMessageHeader$FileMessageHeaderSerializer.serialize(FileMessageHeader.java:208) ~[apache-cassandra-3.3.jar:3.3]
    at org.apache.cassandra.streaming.messages.OutgoingFileMessage.serialize(OutgoingFileMessage.java:84) ~[apache-cassandra-3.3.jar:3.3]
    at org.apache.cassandra.streaming.messages.OutgoingFileMessage$1.serialize(OutgoingFileMessage.java:48) ~[apache-cassandra-3.3.jar:3.3]
    at org.apache.cassandra.streaming.messages.OutgoingFileMessage$1.serialize(OutgoingFileMessage.java:40) ~[apache-cassandra-3.3.jar:3.3]
    at org.apache.cassandra.streaming.messages.StreamMessage.serialize(StreamMessage.java:48) ~[apache-cassandra-3.3.jar:3.3]
    at org.apache.cassandra.streaming.ConnectionHandler$OutgoingMessageHandler.sendMessage(ConnectionHandler.java:363) ~[apache-cassandra-3.3.jar:3.3]
    at org.apache.cassandra.streaming.ConnectionHandler$OutgoingMessageHandler.run(ConnectionHandler.java:335) ~[apache-cassandra-3.3.jar:3.3]
    at java.lang.Thread.run(Thread.java:745) [na:1.8.0_72-internal]

当我执行nodetool引导恢复时,它再次开始流数据,但在一些抛出相同的错误之后。

cassandra 3.3 中是否有任何错误或者我可能做错了什么。

最佳答案

关于这个ticket :

你检查过这个,也许有可能的解决方案吗?

  1. 获取您的架构:DESC SCHEMA;
  2. 在新节点上使用 cqlsh。
  3. 导入架构。
  4. 将新节点添加到集群。

或者您可以更新到 Cassandra 3.4

//编辑 桑吉夫修复了它。 SSTable 不在 Cassandra 版本中。

nodetool upgradesstables

解决了这个问题。

关于java - 缩放cassandra流错误(空指针异常),我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/37959645/

相关文章:

java - Optaplanner 解决过程中出现空指针异常 - 交叉引用对象和 ReflectionPropertyAccessor 类

java - Gson isJsonObject() 抛出 NullPointerException

java - 相等检查后使用 Long 的 NullPointerException

java - 使用 Apache Spark 进行实时分析

cassandra - 我应该为 Cassandra 提交日志和数据使用不同的 HDD 吗?

cassandra - 从 Cassandra 集群导出所有数据的最佳方式是什么?

java - 从 Android 应用程序通过电子邮件发送崩溃报告

java - 使用Java中的xpath查询表达式获取XML中根元素的属性

java - Selenium 2.25.0 是否支持 Firefox 14?

java - 根据正则表达式分割字符串