首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >JanusGraph液滴抛出OperationTimedOutException

JanusGraph液滴抛出OperationTimedOutException
EN

Stack Overflow用户
提问于 2018-03-23 17:54:45
回答 1查看 428关注 0票数 1

在尝试删除CentOS图时,我们在JanusGraph中一致地观察到以下错误。我们使用Janusgraph版本0.2.0和3节点Cassandra集群作为后端。然而,相同的命令在Ubuntu中工作。

NAME="CentOS Linux“VERSION=7(核心)”ID="centos“ID_LIKE=”VERSION_ID=7

代码语言:javascript
复制
     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)

任何帮助都是非常感谢的。

谢谢

EN

回答 1

Stack Overflow用户

发布于 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驱动程序方法。连接器为您处理这个问题,不需要更改它。

票数 2
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/49455730

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档