Cassandra cqlsh shell 上的协调器节点超时

Question

我是 cassandra 的新手，正在尝试在两台 Mac 机器上进行多节点设置。它不是datastax casandra。 比如我的IP是10.100.1.12，其他机器IP是10.100.1.15。我在这台机器上的 cassandra.yaml 文件中更改了以下属性：

10.100.1.15:

• 种子：“127.0.0.1,10.100.1.12,10.100.1.15”
• listen_address: 10.100.1.15
• rpc_address: 10.100.1.15
• endpoint_snitch：GossipingPropertyFileSnitch

10.100.1.12:

• 种子：“127.0.0.1,10.100.1.12,10.100.1.15”

• listen_address：10.100.1.12

• rpc_address：10.100.1.12

• endpoint_snitch：GossipingPropertyFileSnitch

  cassandra 运行良好 cqlsh 也使用命令打开 bin/cqlsh 10.100.1.12

但是当我试图检索表的数量时，它会向我显示错误：

ReadTimeout：来自服务器的错误：code=1200 [协调节点超时等待副本节点的响应] message="操作超时 - 仅收到 0 个响应。" info={'received_responses': 0, 'required_responses': 1, '一致性': 'ONE'}

我尝试将 read_request_timeout_in_ms 属性从 5000 更改为 20000，但我仍然遇到相同的错误。谁能帮助我做错了什么？

表架构如下：

cqlsh:app_auditor> describe table traffic_data;

CREATE TABLE app_auditor.traffic_data (
    current_time bigint PRIMARY KEY,
    appid bigint,
    attributes map<text, text>,
    device bigint,
    flow_type text,
    message_time bigint
) WITH bloom_filter_fp_chance = 0.01
    AND caching = {'keys': 'ALL', 'rows_per_partition': 'NONE'}
    AND comment = ''
    AND compaction = {'class': 'org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy', 'max_threshold': '32', 'min_threshold': '4'}
    AND compression = {'chunk_length_in_kb': '64', 'class': 'org.apache.cassandra.io.compress.LZ4Compressor'}
    AND crc_check_chance = 1.0
    AND dclocal_read_repair_chance = 0.1
    AND default_time_to_live = 0
    AND gc_grace_seconds = 86400
    AND max_index_interval = 2048
    AND memtable_flush_period_in_ms = 0
    AND min_index_interval = 128
    AND read_repair_chance = 0.0
    AND speculative_retry = '99PERCENTILE';

我使用的计数查询是 从 traffic_data 中选择 count(*)；

Answer 1

在 Cassandra 中，count(*) 非常昂贵，cassandra 需要扫描所有节点的所有行才能给你计数，这就是它给你超时异常的原因。

而不是使用 count(*) 维护一个计数器表，如下所示：

CREATE TABLE traffic_counter (
    type int PRIMARY KEY,
    traffic_count counter
);

当一个数据插入到traffic_data数据中时，增加traffic_count的值

UPDATE traffic_counter SET traffic_count = traffic_count + 1 WHERE type = 0;

现在您可以非常有效地选择流量计数。

SELECT traffic_count FROM traffic_counter WHERE type = 0;