- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在运行 spark-cassandra-connector 并遇到了一个奇怪的问题:我将 spark-shell 运行为:
bin/spark-shell --packages datastax:spark-cassandra-connector:2.0.0-M2-s_2.1
然后我运行以下命令:
import com.datastax.spark.connector._
val rdd = sc.cassandraTable("test_spark", "test")
println(rdd.first)
# CassandraRow{id: 2, name: john, age: 29}
问题是以下命令会出错:
rdd.take(1).foreach(println)
# CassandraRow{id: 2, name: john, age: 29}
rdd.take(2).foreach(println)
# Caused by: com.datastax.driver.core.exceptions.UnavailableException: Not enough replicas available for query at consistency LOCAL_ONE (1 required but only 0 alive)
# at com.datastax.driver.core.exceptions.UnavailableException.copy(UnavailableException.java:128)
# at com.datastax.driver.core.Responses$Error.asException(Responses.java:114)
# at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:467)
# at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1012)
# at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:935)
# at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
下面的命令只是挂起:
println(rdd.count)
我的 Cassandra key 空间似乎具有正确的复制因子:
describe test_spark;
CREATE KEYSPACE test_spark WITH replication = {'class': 'SimpleStrategy', 'replication_factor': '3'} AND durable_writes = true;
如何解决上述两个错误?
最佳答案
我假设您在使用 LOCAL_ONE
(spark 连接器默认值)一致性时遇到了 SimpleStrategy 和 multi-dc 的问题。它会在本地 DC 中寻找一个节点来发出请求,但是有可能所有副本都存在于不同的 DC 中并且不满足要求。 ( CASSANDRA-12053 )
如果你change your consistency level (input.consistency.level
to ONE
) 我想会解决的。您还应该真正考虑改用网络拓扑策略。
关于apache-spark - 没有足够的副本可用于一致性 LOCAL_ONE 的查询(需要 1 个,但只有 0 个存活),我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42446887/
我更喜欢使用 io_service 的方式是在应用程序启动时创建一个线程来执行 io_service的运行方法。问题是,如果 io_service 没有任务,它的 run 方法立即返回并且线程终止。
我有一个调用异步方法的 BackgroundWorker。 async 方法提供了一个回调参数,让我知道它已完成。 //Bunch of stuff to prep for the call happ
我正在使用Gitlab Autodevops在我的kubernetes集群上部署应用程序。该应用应始终仅运行一个实例。 问题是,在更新过程中,Helm在新的Pod准备就绪之前会杀死当前正在运行的Pod
在页面刷新后显示 ExtJs 应用程序的最佳方式是什么? 示例:位于 x,y 位置的窗口带有一些面板。 最佳答案 查看 stateId 属性以及在 ExtJs 中如何保存状态:http://docs.
我必须重定向到 zk 中的 tel:**** 链接,并在用户完成调用后,将他重定向到另一个页面。问题是,当我单击链接时,ZK 认为我将离开浏览器,并自动完成我的客户端 session (尽管我确实在页
我有一个适用于 IOS 的位置跟踪器应用程序,即使应用程序处于后台模式,它也应该发送当前位置。但是当应用程序进入后台模式时,socket.io 就会死掉。有没有办法让它保持活力? 最佳答案 您不应将
我正在使用 C# MVC 开发 Web 应用程序并使用 Session 在多个请求之间保留数据。 有时 session 超时,所以我想办法让它保持事件状态,并在 stackoverflow 中找到了一
我从 Activity B 启动 Activity A 。但是当我启动 A 时, B 被摧毁了。结果 A 暂时显示,然后被销毁。即使在 B 被摧毁后,我如何让 A 活着。这就是我从 B 启动 A 的方
所以,即使在输入 onError() 之后,我也想保持 observable keep alive(不丢弃),所以我可以输入 onNext() 我已经关注this answer 通过添加 .catch
我是一名优秀的程序员,十分优秀!