Cassandra 2.1.10 上的流失败错误

Question

我正在尝试让两个节点加入现有的 4 个节点的 cassandra 集群。引导节点时，我面临 Stream failed 错误。对于其中一个节点，我尝试将 auto_bootstrap 设置为 false，在这种情况下，它加入了集群，然后我进行了 nodetool 修复。对于导致 Stream failed 错误的原因，我真的一无所知。我什至尝试在被引导的节点上将 'streaming_socket_timeout_in_ms' 设置为 1 小时，但它没有帮助。 nodetool scrub 也在源节点上试过了

错误摘录：

INFO  [StreamReceiveTask:2] 2016-08-30 09:23:26,316 StreamResultFuture.java:180 - [Stream #56d33930-6e93-11e6-a7ae-c71303d146a8] Session with <source_ip>/<source_ip> is complete
WARN  [StreamReceiveTask:2] 2016-08-30 09:23:26,318 StreamResultFuture.java:207 - [Stream #56d33930-6e93-11e6-a7ae-c71303d146a8] Stream failed
ERROR [main] 2016-08-30 09:23:26,322 CassandraDaemon.java:579 - Exception encountered during startup
java.lang.RuntimeException: Error during boostrap: Stream failed
    at org.apache.cassandra.dht.BootStrapper.bootstrap(BootStrapper.java:86) ~[apache-cassandra-2.1.10.jar:2.1.10]
    at org.apache.cassandra.service.StorageService.bootstrap(StorageService.java:1148) ~[apache-cassandra-2.1.10.jar:2.1.10]
    at org.apache.cassandra.service.StorageService.joinTokenRing(StorageService.java:938) ~[apache-cassandra-2.1.10.jar:2.1.10]
    at org.apache.cassandra.service.StorageService.initServer(StorageService.java:734) ~[apache-cassandra-2.1.10.jar:2.1.10]
    at org.apache.cassandra.service.StorageService.initServer(StorageService.java:611) ~[apache-cassandra-2.1.10.jar:2.1.10]
    at org.apache.cassandra.service.CassandraDaemon.setup(CassandraDaemon.java:387) [apache-cassandra-2.1.10.jar:2.1.10]
    at org.apache.cassandra.service.CassandraDaemon.activate(CassandraDaemon.java:562) [apache-cassandra-2.1.10.jar:2.1.10]
    at org.apache.cassandra.service.CassandraDaemon.main(CassandraDaemon.java:651) [apache-cassandra-2.1.10.jar:2.1.10]
Caused by: org.apache.cassandra.streaming.StreamException: Stream failed
    at org.apache.cassandra.streaming.management.StreamEventJMXNotifier.onFailure(StreamEventJMXNotifier.java:85) ~[apache-cassandra-2.1.10.jar:2.1.10]
    at com.google.common.util.concurrent.Futures$4.run(Futures.java:1172) ~[guava-16.0.jar:na]
    at com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService.execute(MoreExecutors.java:297) ~[guava-16.0.jar:na]
    at com.google.common.util.concurrent.ExecutionList.executeListener(ExecutionList.java:156) ~[guava-16.0.jar:na]
    at com.google.common.util.concurrent.ExecutionList.execute(ExecutionList.java:145) ~[guava-16.0.jar:na]
    at com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:202) ~[guava-16.0.jar:na]
    at org.apache.cassandra.streaming.StreamResultFuture.maybeComplete(StreamResultFuture.java:208) ~[apache-cassandra-2.1.10.jar:2.1.10]
    at org.apache.cassandra.streaming.StreamResultFuture.handleSessionComplete(StreamResultFuture.java:184) ~[apache-cassandra-2.1.10.jar:2.1.10]
    at org.apache.cassandra.streaming.StreamSession.closeSession(StreamSession.java:415) ~[apache-cassandra-2.1.10.jar:2.1.10]
    at org.apache.cassandra.streaming.StreamSession.maybeCompleted(StreamSession.java:688) ~[apache-cassandra-2.1.10.jar:2.1.10]
    at org.apache.cassandra.streaming.StreamSession.taskCompleted(StreamSession.java:651) ~[apache-cassandra-2.1.10.jar:2.1.10]
    at org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.run(StreamReceiveTask.java:139) ~[apache-cassandra-2.1.10.jar:2.1.10]
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) ~[na:1.7.0_75]
    at java.util.concurrent.FutureTask.run(FutureTask.java:262) ~[na:1.7.0_75]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) ~[na:1.7.0_75]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) ~[na:1.7.0_75]
    at java.lang.Thread.run(Thread.java:745) ~[na:1.7.0_75]
WARN  [StorageServiceShutdownHook] 2016-08-30 09:23:26,324 Gossiper.java:1450 - No local state or state is in silent shutdown, not announcing shutdown
INFO  [StorageServiceShutdownHook] 2016-08-30 09:23:26,324 MessagingService.java:735 - Waiting for messaging service to quiesce
INFO  [ACCEPT-/10.227.200.41] 2016-08-30 09:23:26,324 MessagingService.java:1011 - MessagingService has terminated the accept() thread

Answer 1

根据关于将节点添加到集群的文档 (http://docs.datastax.com/en/cassandra/2.1/cassandra/operations/ops_add_node_to_cluster_t.html)，您不应将 auto_bootstrap 设置为 false

在 cassandra.yaml 和 cassandra-topology.properties 或 cassandra-rackdc.properties 配置文件中设置以下属性：

auto_bootstrap - 此属性未列在默认的 cassandra.yaml 配置文件中，但可能已被其他操作添加并设置为 false。如果没有在 cassandra.yaml 中定义，Cassandra 使用 true 作为默认值。对于此操作，请在 cassandra.yaml 文件中搜索此属性。 如果存在，请将其设置为 true 或将其删除。

话虽如此，我在 2.1.11 上，遇到和你一样的问题。