如何为cassandra设置读取请求超时

guicsvcw  于 2021-06-10  发布在  Cassandra
关注(0)|答案(1)|浏览(492)

我尝试为cassandra创建具有不同读取请求超时的新端点。具有大数据请求的大超时的端点响应。我找到了带有com.datastax.cassandra驱动程序的scala代码和带有read\u request\u timeout参数的cassandra-default.yaml。如何在cluster builder或代码中的其他位置设置读取请求超时?

Cluster
      .builder
      .addContactPoints(cassandraHost.split(","): _*)
      .withPort(cassandraPort)
      .withRetryPolicy(DefaultRetryPolicy.INSTANCE)
      .withLoadBalancingPolicy(
        new TokenAwarePolicy(DCAwareRoundRobinPolicy.builder().build())).build

# How long the coordinator should wait for read operations to complete

read_request_timeout_in_ms: 5000
hof1towb

hof1towb1#

在查询级别设置,使用:

session.execute(
        new SimpleStatement("CQL HERE").setReadTimeoutMillis(65000));

如果要在群集构建时设置,请使用:

Cluster cluster = Cluster.builder()
        .addContactPoint("127.0.0.1")
        .withSocketOptions(
                new SocketOptions()
                        .setConnectTimeoutMillis(2000))
        .build();

插座选项

相关问题