在尝试删除CentOS图时,我们在JanusGraph中一致地观察到以下错误。我们使用Janusgraph版本0.2.0和3节点Cassandra集群作为后端。然而,相同的命令在Ubuntu中工作。
NAME="CentOS Linux“VERSION=7(核心)”ID="centos“ID_LIKE=”VERSION_ID=7
gremlin> JanusGraphFactory.drop(g);
13:55:59 WARN com.datastax.driver.core.RequestHandler - Not retrying statement because it is not idempotent (this message will be logged only once).
Note that this version of the driver changes the default retry behavior for non-idempotent statements: they won't be automatically retried anymore.
The driver marks statements non-idempotent by default, so you should explicitly call setIdempotent(true) if your statements are safe to retry.
com.datastax.driver.core.exceptions.OperationTimedOutException: [/xxx.xxx.xxx.x:9042] Timed out waiting for server response
at com.datastax.driver.core.exceptions.OperationTimedOutException.copy(OperationTimedOutException.java:44)
at com.datastax.driver.core.exceptions.OperationTimedOutException.copy(OperationTimedOutException.java:26)
at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37)
at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:245)
at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:68)
at org.janusgraph.diskstorage.cql.CQLStoreManager.clearStorage(CQLStoreManager.java:334)
at org.janusgraph.diskstorage.Backend.clearStorage(Backend.java:589)
at org.janusgraph.core.JanusGraphFactory.drop(JanusGraphFactory.java:216)
at org.janusgraph.core.JanusGraphFactory$drop$0.call(Unknown Source)任何帮助都是非常感谢的。
谢谢
发布于 2018-03-23 18:02:47
当使用火花作业执行Cassandra操作(批处理执行-插入和更新两个表上的操作)时,我得到了“所有主机尝试查询失败-COMDataStax.Driver.core. OperationTimedOutException”错误。
造成这种情况的最常见原因是Spark能够以比Cassandra更快的速度发出写请求。这可能导致GC问题,并建立提示。如果您的应用程序是这样的,请使用以下选项尝试降低并发写入的数量和当前的批处理大小。
spark.cassandra.output.batch.size.rows spark.cassandra.output.concurrent.writes
或在连接器的版本中大于或等于1.2.0集
spark.cassandra.output.throughput_mb_per_sec
这将允许您控制写入C*的数据量,每个火花核心每秒。
您不应该使用批处理。
这并不总是正确的,连接器使用本地令牌感知批处理来加快读写速度,但这在定制应用程序中是很棘手的。在许多情况下,异步查询更好或同样好。
setReadTimeout
这是一个DataStax java驱动程序方法。连接器为您处理这个问题,不需要更改它。
https://stackoverflow.com/questions/49455730
复制相似问题